Loading msc/csst-msc-l1-sls.json 0 → 100644 +8 −0 Original line number Diff line number Diff line { "dag_id": "csst-msc-l1-sls", "dag_run_id": "12345", "message": { "obsid": "10109300543790", "chipid": "01" } } msc/csst-msc-l1-sls.yml 0 → 100644 +22 −0 Original line number Diff line number Diff line # 定义DAG的基本信息 dag_id: "csst-msc-l1-sls" # 定义任务 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-sls tag: latest force_pull: true bash_command: "python /pipeline/app/run.py {message}" upstream_tasks: ["task1"] # 定义依赖关系,task2依赖task1 task3: image: csst-msc-l1-sls-extraction-zero tag: latest force_pull: true bash_command: "python /pipeline/app/run.py {message}" upstream_tasks: ["task2"] # 定义依赖关系,task3依赖task2 Loading
msc/csst-msc-l1-sls.json 0 → 100644 +8 −0 Original line number Diff line number Diff line { "dag_id": "csst-msc-l1-sls", "dag_run_id": "12345", "message": { "obsid": "10109300543790", "chipid": "01" } }
msc/csst-msc-l1-sls.yml 0 → 100644 +22 −0 Original line number Diff line number Diff line # 定义DAG的基本信息 dag_id: "csst-msc-l1-sls" # 定义任务 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-sls tag: latest force_pull: true bash_command: "python /pipeline/app/run.py {message}" upstream_tasks: ["task1"] # 定义依赖关系,task2依赖task1 task3: image: csst-msc-l1-sls-extraction-zero tag: latest force_pull: true bash_command: "python /pipeline/app/run.py {message}" upstream_tasks: ["task2"] # 定义依赖关系,task3依赖task2