diff --git a/dags_airflow_fede_default_queue.py b/dags_airflow_fede_default_queue.py index d8be2bd..d4f6504 100644 --- 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/")