소스 검색

fix for xcom pull

Avik Datta 4 년 전
부모
커밋
57ff01ab43
1개의 변경된 파일2개의 추가작업 그리고 2개의 파일을 삭제
  1. 2 2
      dags/dag8_copy_ongoing_seqrun.py

+ 2 - 2
dags/dag8_copy_ongoing_seqrun.py

@@ -102,7 +102,7 @@ def copy_seqrun_manifest_file(**context):
     remote_file_path = ti.xcom_pull(task_ids=xcom_pull_task_ids)
     if remote_file_path is not None and \
        not isinstance(remote_file_path,str):
-      remote_file_path = remote_file_path.decode()
+      remote_file_path = remote_file_path.decode().strip('\n')
     tmp_work_dir = get_temp_dir(use_ephemeral_space=True)
     local_file_path = \
       os.path.join(
@@ -140,7 +140,7 @@ def get_seqrun_chunks(**context):
     file_path = ti.xcom_pull(task_ids=xcom_pull_task_ids)
     if file_path is not None and \
        not isinstance(file_path,str):
-      file_path = file_path.decode()
+      file_path = file_path.decode().strip('\n')
     check_file_path(file_path)
     file_data = read_json_data(file_path)
     chunk_size = None