Run black linter to make update-pycodestyle happy

Author: moshevayner

config/__init__.py

@@ -15,8 +15,13 @@
 import os
 from .config_exception import ConfigException
 from .incluster_config import load_incluster_config
-from .kube_config import (list_kube_config_contexts, load_kube_config,
-                          load_kube_config_from_dict, new_client_from_config, KUBE_CONFIG_DEFAULT_LOCATION)
+from .kube_config import (
+    list_kube_config_contexts,
+    load_kube_config,
+    load_kube_config_from_dict,
+    new_client_from_config,
+    KUBE_CONFIG_DEFAULT_LOCATION,
+)
 
 
 def load_config(**kwargs):
@@ -28,9 +33,15 @@ def load_config(**kwargs):
     :param kwargs: A combination of all possible kwargs that can be passed to either load_kube_config or
     load_incluster_config functions.
     """
-    if "kube_config_path" in kwargs.keys() or os.path.exists(KUBE_CONFIG_DEFAULT_LOCATION):
+    if "kube_config_path" in kwargs.keys() or os.path.exists(
+        KUBE_CONFIG_DEFAULT_LOCATION
+    ):
         load_kube_config(**kwargs)
     else:
-        print("kube_config_path not provided and default location ({0}) does not exist. "
-              "Using inCluster Config. This might not work.".format(KUBE_CONFIG_DEFAULT_LOCATION))
+        print(
+            "kube_config_path not provided and default location ({0}) does not exist. "
+            "Using inCluster Config. This might not work.".format(
+                KUBE_CONFIG_DEFAULT_LOCATION
+            )
+        )
         load_incluster_config(**kwargs)

watch/watch.py

@@ -32,30 +32,31 @@
 PY2 = sys.version_info[0] == 2
 if PY2:
     import httplib
+
     HTTP_STATUS_GONE = httplib.GONE
 else:
     import http
+
     HTTP_STATUS_GONE = http.HTTPStatus.GONE
 
 
 class SimpleNamespace:
-
     def __init__(self, **kwargs):
         self.__dict__.update(kwargs)
 
 
 def _find_return_type(func):
     for line in pydoc.getdoc(func).splitlines():
         if line.startswith(PYDOC_RETURN_LABEL):
-            return line[len(PYDOC_RETURN_LABEL):].strip()
+            return line[len(PYDOC_RETURN_LABEL) :].strip()
     return ""
 
 
 def iter_resp_lines(resp):
     prev = ""
     for seg in resp.read_chunked(decode_content=False):
         if isinstance(seg, bytes):
-            seg = seg.decode('utf8')
+            seg = seg.decode("utf8")
         seg = prev + seg
         lines = seg.split("\n")
         if not seg.endswith("\n"):
@@ -69,7 +70,6 @@ def iter_resp_lines(resp):
 
 
 class Watch(object):
-
     def __init__(self, return_type=None):
         self._raw_return_type = return_type
         self._stop = False
@@ -84,29 +84,31 @@ def get_return_type(self, func):
             return self._raw_return_type
         return_type = _find_return_type(func)
         if return_type.endswith(TYPE_LIST_SUFFIX):
-            return return_type[:-len(TYPE_LIST_SUFFIX)]
+            return return_type[: -len(TYPE_LIST_SUFFIX)]
         return return_type
 
     def get_watch_argument_name(self, func):
         if PYDOC_FOLLOW_PARAM in pydoc.getdoc(func):
-            return 'follow'
+            return "follow"
         else:
-            return 'watch'
+            return "watch"
 
     def unmarshal_event(self, data, return_type):
         js = json.loads(data)
-        js['raw_object'] = js['object']
-        if return_type and js['type'] != 'ERROR':
-            obj = SimpleNamespace(data=json.dumps(js['raw_object']))
-            js['object'] = self._api_client.deserialize(obj, return_type)
-            if hasattr(js['object'], 'metadata'):
-                self.resource_version = js['object'].metadata.resource_version
+        js["raw_object"] = js["object"]
+        if return_type and js["type"] != "ERROR":
+            obj = SimpleNamespace(data=json.dumps(js["raw_object"]))
+            js["object"] = self._api_client.deserialize(obj, return_type)
+            if hasattr(js["object"], "metadata"):
+                self.resource_version = js["object"].metadata.resource_version
             # For custom objects that we don't have model defined, json
             # deserialization results in dictionary
-            elif (isinstance(js['object'], dict) and 'metadata' in js['object']
-                  and 'resourceVersion' in js['object']['metadata']):
-                self.resource_version = js['object']['metadata'][
-                    'resourceVersion']
+            elif (
+                isinstance(js["object"], dict)
+                and "metadata" in js["object"]
+                and "resourceVersion" in js["object"]["metadata"]
+            ):
+                self.resource_version = js["object"]["metadata"]["resourceVersion"]
         return js
 
     def stream(self, func, *args, **kwargs):
@@ -147,13 +149,13 @@ def stream(self, func, *args, **kwargs):
         return_type = self.get_return_type(func)
         watch_arg = self.get_watch_argument_name(func)
         kwargs[watch_arg] = True
-        kwargs['_preload_content'] = False
-        if 'resource_version' in kwargs:
-            self.resource_version = kwargs['resource_version']
+        kwargs["_preload_content"] = False
+        if "resource_version" in kwargs:
+            self.resource_version = kwargs["resource_version"]
 
         # Do not attempt retries if user specifies a timeout.
         # We want to ensure we are returning within that timeout.
-        disable_retries = ('timeout_seconds' in kwargs)
+        disable_retries = "timeout_seconds" in kwargs
         retry_after_410 = False
         while True:
             resp = func(*args, **kwargs)
@@ -163,20 +165,22 @@ def stream(self, func, *args, **kwargs):
                     # return raw string when we are streaming log
                     if watch_arg == "watch":
                         event = self.unmarshal_event(line, return_type)
-                        if isinstance(event, dict) \
-                                and event['type'] == 'ERROR':
-                            obj = event['raw_object']
+                        if isinstance(event, dict) and event["type"] == "ERROR":
+                            obj = event["raw_object"]
                             # Current request expired, let's retry, (if enabled)
                             # but only if we have not already retried.
-                            if not disable_retries and not retry_after_410 and \
-                                    obj['code'] == HTTP_STATUS_GONE:
+                            if (
+                                not disable_retries
+                                and not retry_after_410
+                                and obj["code"] == HTTP_STATUS_GONE
+                            ):
                                 retry_after_410 = True
                                 break
                             else:
-                                reason = "%s: %s" % (
-                                    obj['reason'], obj['message'])
+                                reason = "%s: %s" % (obj["reason"], obj["message"])
                                 raise client.rest.ApiException(
-                                    status=obj['code'], reason=reason)
+                                    status=obj["code"], reason=reason
+                                )
                         else:
                             retry_after_410 = False
                             yield event
@@ -188,7 +192,7 @@ def stream(self, func, *args, **kwargs):
                 resp.close()
                 resp.release_conn()
                 if self.resource_version is not None:
-                    kwargs['resource_version'] = self.resource_version
+                    kwargs["resource_version"] = self.resource_version
                 else:
                     self._stop = True