Sync with master

Author: akharit

azure/datalake/store/__init__.py

@@ -9,7 +9,6 @@
 __version__ = "0.0.37"
 
 
-
 from .core import AzureDLFileSystem
 from .multithread import ADLDownloader
 

azure/datalake/store/lib.py

@@ -135,7 +135,6 @@ def get_token_internal():
             code = context.acquire_user_code(resource, client_id)
             print(code['message'])
             out = context.acquire_token_with_device_code(resource, code, client_id)
-
         elif username and password:
             out = context.acquire_token_with_username_password(resource, username,
                                                                password, client_id)
@@ -147,8 +146,8 @@ def get_token_internal():
         else:
             raise ValueError("No authentication method found for credentials")
         return out
-
     out = get_token_internal()
+
     out.update({'access': out['accessToken'], 'resource': resource,
                 'refresh': out.get('refreshToken', False),
                 'time': time.time(), 'tenant': tenant_id, 'client': client_id})
@@ -161,22 +160,22 @@ class DataLakeCredential:
     def __init__(self, token):
         self.token = token
 
-    def signed_session(self, retry_policy=None):
+    def signed_session(self):
         # type: () -> requests.Session
         """Create requests session with any required auth headers applied.
 
         :rtype: requests.Session
         """
         session = requests.Session()
         if time.time() - self.token['time'] > self.token['expiresIn'] - 100:
-            self.refresh_token(retry_poliy=retry_policy)
+            self.refresh_token()
 
         scheme, token = self.token['tokenType'], self.token['access']
         header = "{} {}".format(scheme, token)
         session.headers['Authorization'] = header
         return session
 
-    def refresh_token(self, authority=None, retry_policy=None):
+    def refresh_token(self, authority=None):
         """ Refresh an expired authorization token
 
         Parameters
@@ -294,7 +293,6 @@ def session(self):
             self.local.session = s
         return s
 
-
     def _check_token(self, retry_policy= None):
         @retry_decorator_for_auth(retry_policy=retry_policy)
         def check_token_internal():

azure/datalake/store/retry.py

@@ -86,7 +86,6 @@ def deco_retry(func):
         @wraps(func)
         def f_retry(*args, **kwargs):
             retry_count = -1
-
             while True:
                 last_exception = None
                 retry_count += 1
@@ -108,7 +107,6 @@ def f_retry(*args, **kwargs):
             if last_exception is not None:
                 raise last_exception
             return out
-
         return f_retry
 
     return deco_retry