Browse Source

minor fix

Avik Datta 4 years ago
parent
commit
b187bc603e

+ 3 - 3
dags/dag5_primary_analysis_and_qc_processing.py

@@ -19,9 +19,9 @@ default_args = {
 ## SSH HOOK
 orwell_ssh_hook = \
   SSHHook(
-    key_file=Variable.get('hpc_ssh_key_file'),
-    username=Variable.get('hpc_user'),
-    remote_host=Variable.get('orwell_server_hostname'))
+    key_file=Variable.get('hpc_ssh_key_file',default_var=None),
+    username=Variable.get('hpc_user',default_var=None),
+    remote_host=Variable.get('orwell_server_hostname',default_var=None))
 hpc_hook = SSHHook(ssh_conn_id='hpc_conn')
 
 ## DAG

+ 4 - 3
dags/dag9_tenx_single_cell_immune_profiling.py

@@ -39,7 +39,7 @@ default_args = {
 }
 
 FEATURE_TYPE_LIST = \
-  Variable.get('tenx_single_cell_immune_profiling_feature_types')#.split(',')
+  Variable.get('tenx_single_cell_immune_profiling_feature_types',default_var={})#.split(',')
 
 ## DAG
 dag = \
@@ -193,9 +193,10 @@ with dag:
       task_id='upload_cellranger_report_to_box',
       dag=dag,
       queue='hpc_4G',
-      python_callable=None,
+      python_callable=upload_analysis_file_to_box,
       params={'xcom_pull_task':'load_cellranger_result_to_db',
-              'xcom_pull_files_key':'html_report_file'})
+              'xcom_pull_files_key':'html_report_file',
+              'analysis_tag':'cellranger_multi'})
   upload_cellranger_results_to_irods = \
     PythonOperator(
       task_id='upload_cellranger_results_to_irods',