Explorar o código

fix for dag8 tmp dir

Avik Datta %!s(int64=4) %!d(string=hai) anos
pai
achega
188edaf1bc
Modificáronse 1 ficheiros con 1 adicións e 1 borrados
  1. 1 1
      dags/dag8_copy_ongoing_seqrun.py

+ 1 - 1
dags/dag8_copy_ongoing_seqrun.py

@@ -95,7 +95,7 @@ def copy_seqrun_manifest_file(**context):
     xcom_pull_task_ids = context['params'].get('xcom_pull_task_ids')
     ti = context.get('ti')
     remote_file_path = ti.xcom_pull(task_ids=xcom_pull_task_ids)
-    tmp_work_dir = get_temp_dir(use_ephemeral=True)
+    tmp_work_dir = get_temp_dir(use_ephemeral_space=True)
     local_file_path = \
       os.path.join(
         tmp_work_dir,