Update dags_airflow_fede_k8sexecutor.py

interTwin-eu · Jan 26, 2024 · 0903536 · 0903536
1 parent e25c058
commit 0903536
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/dags_airflow_fede_k8sexecutor.py b/dags_airflow_fede_k8sexecutor.py
@@ -135,7 +135,7 @@ def test_volume_mount():
                     volumes=[
                         k8s.V1Volume(
                             name="shared-empty-dir", 
-                            empty_dir=k8s.V1EmptyDirVolumeSource()
+                            empty_dir=k8s.V1EmptyDirVolumeSource(),
                         ),
                     ],
                 )
@@ -171,7 +171,7 @@ def test_sharedvolume_mount():
                 metadata=k8s.V1ObjectMeta(labels={"release": "stable"})
             )
         }
-        
+
         #############################################################
         # 4) pod with label
         #############################################################
@@ -204,7 +204,7 @@ def other_namespace_task():
         #############################################################
         # Define config for task: pod with image
         #############################################################
-        
+
         worker_container_repository = conf.get(
             "kubernetes_executor", "worker_container_repository"
         )
@@ -220,7 +220,7 @@ def other_namespace_task():
                     containers=[
                         k8s.V1Container(
                             name="base",
-                            image=f"{worker_container_repository}:{worker_container_tag}"
+                            image=f"{worker_container_repository}:{worker_container_tag}",
                         ),
                     ]
                 )