[AIRFLOW-6048] Make K8s Pod Operator's _set_* methods static (#6645)

apache · Nov 23, 2019 · 09ccf29 · 09ccf29
1 parent e37ec9a
commit 09ccf29
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/airflow/contrib/operators/kubernetes_pod_operator.py b/airflow/contrib/operators/kubernetes_pod_operator.py
@@ -266,9 +266,11 @@ def execute(self, context):
         except AirflowException as ex:
             raise AirflowException('Pod Launching failed: {error}'.format(error=ex))
 
-    def _set_resources(self, resources):
+    @staticmethod
+    def _set_resources(resources):
         return [Resources(**resources) if resources else Resources()]
 
-    def _set_name(self, name):
+    @staticmethod
+    def _set_name(name):
         validate_key(name, max_length=63)
         return re.sub(r'[^a-z0-9.-]+', '-', name.lower())