Update dags_airflow_fede_default_queue.py

interTwin-eu · Jan 29, 2024 · 2298e3d · 2298e3d
1 parent 13bd74f
commit 2298e3d
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/dags_airflow_fede_default_queue.py b/dags_airflow_fede_default_queue.py
@@ -69,7 +69,7 @@ def test_annotation():
         #############################################################
         # Define config for task with volume, mount host /tmp/ to /foo/
         #############################################################
-        directory = os.getcwd().replace('\\', '/')
+        directory = os.getcwd().replace('\\', '/')   # "/tmp/"
         print(directory)
         executor_config_volume_mount = {
             "pod_override": k8s.V1Pod(
@@ -87,7 +87,7 @@ def test_annotation():
                     volumes=[
                         k8s.V1Volume(
                             name="test-volume",
-                            host_path=k8s.V1HostPathVolumeSource(path=directory),  # "/tmp/"
+                            host_path=k8s.V1HostPathVolumeSource(path=directory),
                         )
                     ],
                 )
@@ -107,6 +107,7 @@ def test_volume_mount():
             Tests whether the volume has been mounted.
             """
 
+            log.info("Path on host "+directory)
             foo_dir = Path("/foo")
             if foo_dir.exists():
                 log.info("Can open /foo/")