Commit eedfc4f8 authored by BO ZHANG's avatar BO ZHANG 🏀
Browse files

test python operator

parent dc33196d

airflow/docker/dags/csst-msc-l1.conditional_trigger.py

+1 −4
Original line number Diff line number Diff line
@@ -28,10 +28,7 @@ def process_observation(**context): 
    """

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

    params = context["params"]

    obs_id = params["obs_id"]

    detector = params["detector"]

    print(f"🚀 开始处理观测ID: {obs_id}, 探测器: {detector}")



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

    return "great"