Commit 25fcca64 authored by BO ZHANG's avatar BO ZHANG 🏀
Browse files

Update msc/csst-msc-l1-mbi.yml, msc/csst-msc-l1-mbi.json

parent 33d367be

msc/csst-msc-l1.json→msc/csst-msc-l1-mbi.json

+2 −2
Original line number Diff line number Diff line 
{

    "dag": "csst-msc-l1",

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

    "parameters": {

        "dag_run_id": 12345,

        "message": {

            "obsid": "10109312345678",

            "obsid": "10109300543790",

            "chipid": "09"

        }

    }

msc/csst-msc-l1.yml→msc/csst-msc-l1-mbi.yml

+6 −7
Original line number Diff line number Diff line 
# 定义DAG的基本信息

csst-msc-l1-mbi:

  dag_id: ""

dag_id: "csst-msc-l1-mbi"

  

# 定义任务

tasks:

  task1:

    image: csst-msc-l1-qc0

    tag: latest

    force_pull: true

    bash_command: "echo 'Task 1 is running'"

    dag: my_dag

  task2:

    image: csst-msc-l1-mbi

    tag: latest

    force_pull: true

    bash_command: "echo 'Task 2 is running'"

    dag: my_dag

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

  task3:

    image: csst-msc-l1-mbi-photmix

    tag: latest

    bash_command: "echo 'Task 3 is running'"

    dag: my_dag

    upstream_task_ids: ["task2"]  # 定义依赖关系，task3依赖task2
 
    force_pull: true

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

    upstream_task_ids: ["task2", "task1"]  # 定义依赖关系，task3依赖task2