浏览代码

fix for picard input fetching

Avik Datta 4 年之前
父节点
当前提交
2c50862839
共有 1 个文件被更改,包括 4 次插入4 次删除
  1. 4 4
      dags/dag9_tenx_single_cell_immune_profiling.py

+ 4 - 4
dags/dag9_tenx_single_cell_immune_profiling.py

@@ -577,7 +577,7 @@ with dag:
       dag=dag,
       queue='hpc_4G',
       python_callable=run_picard_for_cellranger,
-      params={'xcom_pull_files_key':'cellranger_output',
+      params={'xcom_pull_files_key':'run_picard_alignment_summary',
               'xcom_pull_task':'copy_bam_for_parallel_runs',
               'analysis_description_xcom_pull_task':'fetch_analysis_info',
               'analysis_description_xcom_key':'analysis_description',
@@ -597,7 +597,7 @@ with dag:
       dag=dag,
       queue='hpc_4G',
       python_callable=run_picard_for_cellranger,
-      params={'xcom_pull_files_key':'cellranger_output',
+      params={'xcom_pull_files_key':'run_picard_qual_summary',
               'xcom_pull_task':'copy_bam_for_parallel_runs',
               'analysis_description_xcom_pull_task':'fetch_analysis_info',
               'analysis_description_xcom_key':'analysis_description',
@@ -617,7 +617,7 @@ with dag:
       dag=dag,
       queue='hpc_4G',
       python_callable=run_picard_for_cellranger,
-      params={'xcom_pull_files_key':'cellranger_output',
+      params={'xcom_pull_files_key':'run_picard_rna_summary',
               'xcom_pull_task':'copy_bam_for_parallel_runs',
               'analysis_description_xcom_pull_task':'fetch_analysis_info',
               'analysis_description_xcom_key':'analysis_description',
@@ -637,7 +637,7 @@ with dag:
       dag=dag,
       queue='hpc_4G',
       python_callable=run_picard_for_cellranger,
-      params={'xcom_pull_files_key':'cellranger_output',
+      params={'xcom_pull_files_key':'run_picard_gc_summary',
               'xcom_pull_task':'copy_bam_for_parallel_runs',
               'analysis_description_xcom_pull_task':'fetch_analysis_info',
               'analysis_description_xcom_key':'analysis_description',