Commit e1ca1c36 authored by Tan Siyuan's avatar Tan Siyuan
Browse files

hstdm add dag

parent 3ff3bc68

csst_dag/dag_rules/hstdm.toml

0 → 100644
+16 −0
Original line number Diff line number Diff line 
[csst-hstdm-l1]

obsid = [

    "501", #

    "502", #

    "503", #

    "504" #

]

chipid = [

    "01", "02"

]

projid=[

  "501"# not yet determined 

  

]

csst_dag/dag_templates/csst-hstdm-l1.json

0 → 100644
+11 −0
Original line number Diff line number Diff line 
 {

    "dag_id": "csst-hstdm-l1",

    "dag_run_id": "12345",

    "batch_id": "hstdm-001-reduction-v2",

    "message": {

        "obsid": "50100000002",

        "chipid": "01",

        "dataset": "hstdm-001",

        "batch_id": "msc-001-reduction-v2"

    }

}
 
 No newline at end of file

csst_dag/dag_templates/csst-hstdm-l1.yml

0 → 100644
+16 −0
Original line number Diff line number Diff line 
# 定义DAG的基本信息

dag_id: "csst-hstdm-l1"

  

# 定义任务

tasks:

  task1:

    image: csst-hstdm-l1-qc0

    tag: latest

    force_pull: true

    bash_command: "python /pipeline/app/run.py {message}"

  task2:

    image: csst-hstdm-l1

    tag: latest

    force_pull: true

    bash_command: "python /pipeline/app/run.py {message}"

    upstream_tasks: ["task1"]  # 定义依赖关系，task2依赖task1