ソースを参照

passing task as list from variable

Avik Datta 4 年 前
コミット
5876305ac2
2 ファイル変更3 行追加2 行削除
  1. 1 1
      airflow_var/var.json
  2. 2 1
      dags/dag9_tenx_single_cell_immune_profiling.py

+ 1 - 1
airflow_var/var.json

@@ -33,7 +33,7 @@
   "woolf_server_hostname":"woolf.med.ic.ac.uk",
   "eliot_server_hostname":"eliot.med.ic.ac.uk",
   "igf_lims_server_hostname":"igf-lims.cc.ic.ac.uk",
-  "tenx_single_cell_immune_profiling_feature_types": "gene_expression,vdj,vdj-t,vdj-b,antibody_capture,antigen_capture,crisper_guide_capture",
+  "tenx_single_cell_immune_profiling_feature_types": ["gene_expression","vdj","vdj-t","vdj-b","antibody_capture","antigen_capture","crisper_guide_capture"],
   "scanpy_single_sample_template":"",
   "scanpy_notebook_image":"",
   "scirpy_single_sample_template":"",

+ 2 - 1
dags/dag9_tenx_single_cell_immune_profiling.py

@@ -39,7 +39,8 @@ default_args = {
     'provide_context': True,
 }
 
-FEATURE_TYPE_LIST = Variable.get('tenx_single_cell_immune_profiling_feature_types').split(',')
+FEATURE_TYPE_LIST = \
+  Variable.get('tenx_single_cell_immune_profiling_feature_types',deserialize_json=True)#.split(',')
 
 ## DAG
 dag = \