Commit 90f8a9f8 authored by BO ZHANG's avatar BO ZHANG 🏀
Browse files

update DAG and message template

parent a38a0750
...@@ -3,7 +3,9 @@ ...@@ -3,7 +3,9 @@
"dag_id": "csst-msc-l1-mbi", "dag_id": "csst-msc-l1-mbi",
"dag_run_id": "12345", "dag_run_id": "12345",
"dataset": "csst-msc-c9-25sqdeg-v3", "dataset": "csst-msc-c9-25sqdeg-v3",
"batch_id": "msc-093-reduction-v2", "obs_type": "WIDE",
"obsid": "10109300543790", "project_id": "none",
"chipid": "09", "obs_id": "10100543790",
"chip_id": "09",
"batch_id": "csst-msc-c9-25-sqdeg-v3-rdx1"
} }
# 定义DAG的基本信息 - dag_id: diamond
dag_id: "csst-msc-l1-mbi" dag:
tasks:
# 定义任务 - name: QC0
tasks: image: csst-msc-l1-qc0
task1: - name: MBI
image: csst-msc-l1-qc0 dependencies: [QC0]
tag: latest image: csst-msc-l1-mbi
force_pull: true - name: AST
bash_command: "python /pipeline/app/run.py {message}" dependencies: [QC0]
task2: image: csst-msc-l1-ast
image: csst-msc-l1-mbi - name: SSO
tag: latest dependencies: [AST]
force_pull: true template: csst-msc-l1-ast-sso
bash_command: "python /pipeline/app/run.py {message}" \ No newline at end of file
upstream_tasks: ["task1"] # 定义依赖关系,task2依赖task1
task3:
image: csst-msc-l1-mbi-photmix
tag: latest
force_pull: true
bash_command: "python /pipeline/app/run.py {message}"
upstream_tasks: ["task2"] # 定义依赖关系,task3依赖task2
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment