Update pycodestyle

config/exec_provider.py

@@ -23,9 +23,10 @@ from .config_exception import ConfigException
 
 class ExecProvider(object):
     """
-    Implementation of the proposal for out-of-tree client authentication providers
-    as described here --
-    https://github.com/kubernetes/community/blob/master/contributors/design-proposals/auth/kubectl-exec-plugins.md
+    Implementation of the proposal for out-of-tree client
+    authentication providers as described here --
+    https://github.com/kubernetes/community/blob/master/contributors
+    /design-proposals/auth/kubectl-exec-plugins.md
 
     Missing from implementation:
 

config/incluster_config.py

@@ -87,7 +87,8 @@ class InClusterConfigLoader(object):
 
 
 def load_incluster_config():
-    """Use the service account kubernetes gives to pods to connect to kubernetes
+    """
+    Use the service account kubernetes gives to pods to connect to kubernetes
     cluster. It's intended for clients that expect to be running inside a pod
     running on kubernetes. It will raise an exception if called from a process
     not running in a kubernetes environment."""

config/kube_config.py

@@ -556,9 +556,11 @@ def new_client_from_config(
         config_file=None,
         context=None,
         persist_config=True):
-    """Loads configuration the same as load_kube_config but returns an ApiClient
+    """
+    Loads configuration the same as load_kube_config but returns an ApiClient
     to be used with any API object. This will allow the caller to concurrently
-    talk with multiple clusters."""
+    talk with multiple clusters.
+    """
     client_config = type.__call__(Configuration)
     load_kube_config(config_file=config_file, context=context,
                      client_configuration=client_config,

hack/boilerplate/boilerplate.py

@@ -52,7 +52,8 @@ verbose_out = sys.stderr if args.verbose else open("/dev/null", "w")
 def get_refs():
     refs = {}
 
-    for path in glob.glob(os.path.join(args.boilerplate_dir, "boilerplate.*.txt")):
+    for path in glob.glob(os.path.join(
+            args.boilerplate_dir, "boilerplate.*.txt")):
         extension = os.path.basename(path).split(".")[1]
 
         ref_file = open(path, 'r')
@@ -105,7 +106,7 @@ def file_passes(filename, refs, regexs):
                   filename, file=verbose_out)
             return False
 
-    # Replace all occurrences of the regex "2014|2015|2016|2017|2018" with "YEAR"
+    # Replace all occurrences of regex "2014|2015|2016|2017|2018" with "YEAR"
     p = regexs["date"]
     for i, d in enumerate(data):
         (data[i], found) = p.subn('YEAR', d)
@@ -118,7 +119,8 @@ def file_passes(filename, refs, regexs):
               filename, file=verbose_out)
         if args.verbose:
             print(file=verbose_out)
-            for line in difflib.unified_diff(ref, data, 'reference', filename, lineterm=''):
+            for line in difflib.unified_diff(
+                    ref, data, 'reference', filename, lineterm=''):
                 print(line, file=verbose_out)
             print(file=verbose_out)
         return False
@@ -171,9 +173,11 @@ def get_dates():
 
 def get_regexs():
     regexs = {}
-    # Search for "YEAR" which exists in the boilerplate, but shouldn't in the real thing
+    # Search for "YEAR" which exists in the boilerplate,
+    # but shouldn't in the real thing
     regexs["year"] = re.compile('YEAR')
-    # get_dates return 2014, 2015, 2016, 2017, or 2018 until the current year as a regex like: "(2014|2015|2016|2017|2018)";
+    # get_dates return 2014, 2015, 2016, 2017, or 2018 until the current year
+    # as a regex like: "(2014|2015|2016|2017|2018)";
     # company holder names can be anything
     regexs["date"] = re.compile(get_dates())
     # strip #!.* from shell scripts

stream/ws_client.py

@@ -53,7 +53,8 @@ class WSClient:
             header.append("authorization: %s" % headers['authorization'])
 
         if headers and 'sec-websocket-protocol' in headers:
-            header.append("sec-websocket-protocol: %s" % headers['sec-websocket-protocol'])
+            header.append("sec-websocket-protocol: %s" %
+                          headers['sec-websocket-protocol'])
         else:
             header.append("sec-websocket-protocol: v4.channel.k8s.io")
 
@@ -186,8 +187,8 @@ class WSClient:
                     data = data[1:]
                     if data:
                         if channel in [STDOUT_CHANNEL, STDERR_CHANNEL]:
-                            # keeping all messages in the order they received for
-                            # non-blocking call.
+                            # keeping all messages in the order they received
+                            # for non-blocking call.
                             self._all += data
                         if channel not in self._channels:
                             self._channels[channel] = data