Commit 71193d17 authored by BO ZHANG's avatar BO ZHANG 🏀
Browse files

add qc0 and ast DAGs

parent 5d54f74a

csst_dag/dag_templates/csst-msc-l1-ast.json

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

    "dag_id": "csst-msc-l1-ast",

    "dag_run_id": "12345",

    "batch_id": "msc-093-reduction-v2",

    "message": {

        "obsid": "10109300543790",

        "chipid": "09",

        "dataset": "msc-093",

        "batch_id": "msc-093-reduction-v2"

    }

}

csst_dag/dag_templates/csst-msc-l1-ast.yml

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

dag_id: "csst-msc-l1-ast"

  

# 定义任务

tasks:

  task1:

    image: csst-msc-l1-qc0

    tag: latest

    force_pull: true

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

  task2:

    image: csst-msc-l1-ast

    tag: latest

    force_pull: true

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

    upstream_tasks: ["task1"]  # 定义依赖关系，task2依赖task1
 
 No newline at end of file

csst_dag/dag_templates/csst-msc-l1-qc0.json

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

    "dag_id": "csst-msc-l1-qc0",

    "dag_run_id": "12345",

    "batch_id": "msc-093-reduction-v2",

    "message": {

        "obsid": "10109300543790",

        "chipid": "09",

        "dataset": "msc-093",

        "batch_id": "msc-093-reduction-v2"

    }

}

csst_dag/dag_templates/csst-msc-l1-qc0.yml

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

dag_id: "csst-msc-l1-qc0"

  

# 定义任务

tasks:

  task1:

    image: csst-msc-l1-qc0

    tag: latest

    force_pull: true

    bash_command: "python /pipeline/app/run.py {message}"
 
 No newline at end of file