You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ka...@apache.org on 2020/11/03 13:46:27 UTC

[airflow] branch v1-10-test updated: Fix static check

This is an automated email from the ASF dual-hosted git repository.

kaxilnaik pushed a commit to branch v1-10-test
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/v1-10-test by this push:
     new e9232b2  Fix static check
e9232b2 is described below

commit e9232b2ef00771bcb01f2f05bcc0377a466e3acd
Author: Kaxil Naik <ka...@gmail.com>
AuthorDate: Tue Nov 3 13:45:36 2020 +0000

    Fix static check
---
 tests/kubernetes/test_pod_generator.py | 13 +++++++------
 1 file changed, 7 insertions(+), 6 deletions(-)

diff --git a/tests/kubernetes/test_pod_generator.py b/tests/kubernetes/test_pod_generator.py
index a2ab6ff..fed7c97 100644
--- a/tests/kubernetes/test_pod_generator.py
+++ b/tests/kubernetes/test_pod_generator.py
@@ -80,10 +80,10 @@ class TestPodGenerator(unittest.TestCase):
             'kubernetes_executor': 'True'
         }
         self.metadata = {
-            'annotations':  {'dag_id': 'dag_id',
-                              'execution_date': '2020-08-24T00:00:00',
-                              'task_id': 'task_id',
-                              'try_number': '3'},
+            'annotations': {'dag_id': 'dag_id',
+                            'execution_date': '2020-08-24T00:00:00',
+                            'task_id': 'task_id',
+                            'try_number': '3'},
             'labels': self.labels,
             'name': 'pod_id-' + self.static_uuid.hex,
             'namespace': 'namespace'
@@ -1106,7 +1106,8 @@ spec:
             date=parser.parse("23-07-2020"),
             command="test",
             pod_override_object=None,
-            base_worker_pod=k8s.V1Pod(metadata=k8s.V1ObjectMeta(labels={"airflow-test": "airflow-task-pod"},
-                                                              annotations={"my.annotation": "foo"})))
+            base_worker_pod=k8s.V1Pod(
+                metadata=k8s.V1ObjectMeta(labels={"airflow-test": "airflow-task-pod"},
+                                          annotations={"my.annotation": "foo"})))
         self.assertIn("airflow-test", pod.metadata.labels)
         self.assertIn("my.annotation", pod.metadata.annotations)