print context

)

def process_observation(**context):

def dispatch_tasks(**context):

    """

    处理天文观测数据的核心逻辑

    """

    # 1. 从上下文获取DAG参数

    params = context["params"]

    print(f"🚀 获得的上下文为 {context}")

    print(f"🚀 获得的参数为 {params}")

    return "great"

) as dag:

    process_task = PythonOperator(

        task_id="process_observation_data",

        python_callable=process_observation,

        task_id="dispatch_tasks",

        python_callable=dispatch_tasks,

    )

    t1 = BashOperator(