然而,就目前而言,当我尝试创建一个新的cloud composer环境并部署以前工作良好的同一DAG时,我在Airflow Web UI上收到了以下错误消息。并且DAG失败。Broken DAG: [/home/airflow/gcs/dags/xxx.py] Relationships can only be set between Operators; receivedGoogleCloudStorageToGoogleCloudStorageOperator 即使我使用相同的代码并遵循
SET task_instance.state=NULL WHERE task_instance.dag_id = 'test_dag_01' AND task_instance.state IN ('queued', 'scheduled') AND dag_run.dag_id = task_instance.dag_id AND dag_run.execution_date = task_instance.executio