Force apply autopep8

As required by contributing documentation

Author: penguinolog

kubernetes/base/config/__init__.py

@@ -16,9 +16,13 @@
 
 from .config_exception import ConfigException
 from .incluster_config import load_incluster_config
-from .kube_config import (KUBE_CONFIG_DEFAULT_LOCATION,
-                          list_kube_config_contexts, load_kube_config,
-                          load_kube_config_from_dict, new_client_from_config, new_client_from_config_dict)
+from .kube_config import (
+    KUBE_CONFIG_DEFAULT_LOCATION,
+    list_kube_config_contexts,
+    load_kube_config,
+    load_kube_config_from_dict,
+    new_client_from_config,
+    new_client_from_config_dict)
 
 
 def load_config(**kwargs):

kubernetes/base/config/dateutil.py

@@ -52,24 +52,24 @@ def parse_rfc3339(s):
         if not s.tzinfo:
             return s.replace(tzinfo=UTC)
         return s
-    
+
     m = _re_rfc3339.fullmatch(s.strip())
     if m is None:
         raise ValueError(
             f"Invalid RFC3339 datetime: {s!r} "
             "(expected YYYY-MM-DDTHH:MM:SS[.frac][Z|±HH:MM])"
         )
-    
+
     groups = m.groups()
     dt = [0] * 7
     for x in range(6):
         dt[x] = int(groups[x])
-    
+
     us = 0
     if groups[6] is not None:
         partial_sec = float(groups[6].replace(",", "."))
         us = int(MICROSEC_PER_SEC * partial_sec)
-    
+
     tz = UTC
     if groups[7] is not None and groups[7] not in ('Z', 'z', ' '):
         tz_match = _re_timezone.search(groups[7])
@@ -87,7 +87,7 @@ def parse_rfc3339(s):
         if tz_groups[2]:
             minute = int(tz_groups[2])
         tz = TimezoneInfo(hour, minute)
-    
+
     try:
         return datetime.datetime(
             year=dt[0], month=dt[1], day=dt[2],
@@ -99,7 +99,6 @@ def parse_rfc3339(s):
         ) from e
 
 
-
 def format_rfc3339(date_time):
     if date_time.tzinfo is None:
         date_time = date_time.replace(tzinfo=UTC)

kubernetes/base/config/dateutil_test.py

@@ -84,8 +84,6 @@ def test_parse_rfc3339_invalid_formats(self):
             with self.assertRaises(ValueError):
                 parse_rfc3339(invalid_input)
 
-
-
     def test_parse_rfc3339_with_whitespace(self):
         """Test that leading/trailing whitespace is handled"""
         actual = parse_rfc3339("  2017-07-25T04:44:21Z  ")

kubernetes/base/config/exec_provider.py

@@ -58,7 +58,7 @@ def __init__(self, exec_config, cwd, cluster=None):
         else:
             self.cluster = None
         self.cwd = cwd or None
-    
+
     @property
     def shell(self):
         # for windows systems `shell` should be `True`

kubernetes/base/config/exec_provider_test.py

@@ -175,7 +175,10 @@ def test_with_cluster_info(self, mock):
         instance = mock.return_value
         instance.wait.return_value = 0
         instance.communicate.return_value = (self.output_ok, '')
-        ep = ExecProvider(self.input_with_cluster, None, ConfigNode("cluster", {'server': 'name.company.com'}))
+        ep = ExecProvider(
+            self.input_with_cluster, None, ConfigNode(
+                "cluster", {
+                    'server': 'name.company.com'}))
         result = ep.run()
         self.assertTrue(isinstance(result, dict))
         self.assertTrue('token' in result)
@@ -213,8 +216,10 @@ def test_with_cluster_info_from_exec_extension(self, mock):
 
         obj = json.loads(mock.call_args.kwargs["env"]["KUBERNETES_EXEC_INFO"])
         self.assertEqual(obj["spec"]["cluster"]["server"], "name.company.com")
-        self.assertEqual(obj["spec"]["cluster"]["config"]["namespace"], "myproject")
+        self.assertEqual(obj["spec"]["cluster"]["config"]
+                         ["namespace"], "myproject")
         self.assertEqual(obj["spec"]["cluster"]["config"]["name"], "mycluster")
 
+
 if __name__ == '__main__':
     unittest.main()

kubernetes/base/config/kube_config.py

@@ -43,7 +43,6 @@
     google_auth_available = False
 
 
-
 EXPIRY_SKEW_PREVENTION_DELAY = datetime.timedelta(minutes=5)
 KUBE_CONFIG_DEFAULT_LOCATION = os.environ.get('KUBECONFIG', '~/.kube/config')
 ENV_KUBECONFIG_PATH_SEPARATOR = ';' if platform.system() == 'Windows' else ':'
@@ -60,7 +59,10 @@ def _cleanup_temp_files():
     _temp_files = {}
 
 
-def _create_temp_file_with_content(content, temp_file_path=None, force_recreate=False):
+def _create_temp_file_with_content(
+        content,
+        temp_file_path=None,
+        force_recreate=False):
     if len(_temp_files) == 0:
         atexit.register(_cleanup_temp_files)
     # Because we may change context several times, try to remember files we
@@ -143,7 +145,9 @@ def _write_file(self, force_rewrite=False):
             else:
                 content = self._data
             self._file = _create_temp_file_with_content(
-                base64.standard_b64decode(content), self._temp_file_path, force_recreate=force_rewrite)
+                base64.standard_b64decode(content),
+                self._temp_file_path,
+                force_recreate=force_rewrite)
         else:
             self._file = _create_temp_file_with_content(
                 self._data, self._temp_file_path, force_recreate=force_rewrite)
@@ -245,7 +249,7 @@ def _refresh_credentials():
                 'config' in self._user['auth-provider'] and
                     'cmd-path' in self._user['auth-provider']['config']):
                 return _refresh_credentials_with_cmd_path()
-            
+
             # Make the Google auth block optional.
             if google_auth_available:
                 credentials, project_id = google.auth.default(scopes=[
@@ -257,7 +261,7 @@ def _refresh_credentials():
                 return credentials
             else:
                 return None
-            
+
         if get_google_credentials:
             self._get_google_credentials = get_google_credentials
         else:
@@ -314,8 +318,6 @@ def _load_auth_provider_token(self):
         if provider['name'] == 'oidc':
             return self._load_oid_token(provider)
 
-
-
     def _load_gcp_token(self, provider):
         if (('config' not in provider) or
                 ('access-token' not in provider['config']) or
@@ -442,7 +444,10 @@ def _load_from_exec_plugin(self):
             return
         try:
             base_path = self._get_base_path(self._cluster.path)
-            status = ExecProvider(self._user['exec'], base_path, self._cluster).run()
+            status = ExecProvider(
+                self._user['exec'],
+                base_path,
+                self._cluster).run()
             if 'token' in status:
                 self.token = "Bearer %s" % status['token']
             elif 'clientCertificateData' in status:
@@ -535,7 +540,13 @@ def _refresh_api_key(client_configuration):
                 self._set_config(client_configuration)
             client_configuration.refresh_api_key_hook = _refresh_api_key
         # copy these keys directly from self to configuration object
-        keys = ['host', 'ssl_ca_cert', 'cert_file', 'key_file', 'verify_ssl','tls_server_name']
+        keys = [
+            'host',
+            'ssl_ca_cert',
+            'cert_file',
+            'key_file',
+            'verify_ssl',
+            'tls_server_name']
         for key in keys:
             if key in self.__dict__:
                 setattr(client_configuration, key, getattr(self, key))

kubernetes/base/config/kube_config_test.py

@@ -30,14 +30,22 @@
 
 from .config_exception import ConfigException
 from .dateutil import UTC, format_rfc3339, parse_rfc3339
-from .kube_config import (ENV_KUBECONFIG_PATH_SEPARATOR, CommandTokenSource,
-                          ConfigNode, FileOrData, KubeConfigLoader,
-                          KubeConfigMerger, _cleanup_temp_files,
-                          _create_temp_file_with_content,
-                          _get_kube_config_loader,
-                          _get_kube_config_loader_for_yaml_file,
-                          list_kube_config_contexts, load_kube_config,
-                          load_kube_config_from_dict, new_client_from_config, new_client_from_config_dict)
+from .kube_config import (
+    ENV_KUBECONFIG_PATH_SEPARATOR,
+    CommandTokenSource,
+    ConfigNode,
+    FileOrData,
+    KubeConfigLoader,
+    KubeConfigMerger,
+    _cleanup_temp_files,
+    _create_temp_file_with_content,
+    _get_kube_config_loader,
+    _get_kube_config_loader_for_yaml_file,
+    list_kube_config_contexts,
+    load_kube_config,
+    load_kube_config_from_dict,
+    new_client_from_config,
+    new_client_from_config_dict)
 
 BEARER_TOKEN_FORMAT = "Bearer %s"
 
@@ -88,10 +96,10 @@ def _raise_exception(st):
 TEST_PASSWORD = "pass"
 # token for me:pass
 TEST_BASIC_TOKEN = "Basic bWU6cGFzcw=="
-DATETIME_EXPIRY_PAST = datetime.datetime.now(tz=UTC
-                                             ).replace(tzinfo=None) - datetime.timedelta(minutes=PAST_EXPIRY_TIMEDELTA)
-DATETIME_EXPIRY_FUTURE = datetime.datetime.now(tz=UTC
-                                               ).replace(tzinfo=None) + datetime.timedelta(minutes=FUTURE_EXPIRY_TIMEDELTA)
+DATETIME_EXPIRY_PAST = datetime.datetime.now(tz=UTC).replace(
+    tzinfo=None) - datetime.timedelta(minutes=PAST_EXPIRY_TIMEDELTA)
+DATETIME_EXPIRY_FUTURE = datetime.datetime.now(tz=UTC).replace(
+    tzinfo=None) + datetime.timedelta(minutes=FUTURE_EXPIRY_TIMEDELTA)
 TEST_TOKEN_EXPIRY_PAST = _format_expiry_datetime(DATETIME_EXPIRY_PAST)
 
 TEST_SSL_HOST = "https://test-host"
@@ -995,7 +1003,8 @@ def test_oidc_with_refresh(self, mock_ApiClient, mock_OAuth2Session):
 
     @mock.patch('kubernetes.config.kube_config.OAuth2Session.refresh_token')
     @mock.patch('kubernetes.config.kube_config.ApiClient.request')
-    def test_oidc_with_idp_ca_file_refresh(self, mock_ApiClient, mock_OAuth2Session):
+    def test_oidc_with_idp_ca_file_refresh(
+            self, mock_ApiClient, mock_OAuth2Session):
         mock_response = mock.MagicMock()
         type(mock_response).status = mock.PropertyMock(
             return_value=200
@@ -1065,7 +1074,6 @@ def test_oidc_fails_if_invalid_padding_length(self):
             None,
         )
 
-
     def test_user_pass(self):
         expected = FakeConfig(host=TEST_HOST, token=TEST_BASIC_TOKEN)
         actual = FakeConfig()