XComs 在 composer-1.17.1-airflow-2.1.2 的 Xcom 部分中不可见

Question

我在我的气流 DAG 中创建了一个任务，它返回一些值，并且该值应该在气流的 xcom 部分中可见，但不是。 我已设置 do_xcom_push = True 但它仍然不会显示。 在此之前我使用的是 Airflow 2.0.0，并且用于将返回值推送到 xcom 的任务相同，但在 Airflow 2.1.2 中它没有发生。 我不明白我错过了什么。 这是一个气流任务的sn-p：

task = python_operator.PythonOperator(task_id="invoke_cf",python_callable=invoke_cloud_function,do_xcom_push=True)

Answer 1

PythonOperator 默认情况下将 python 可调用的返回值推送到 Xcom。无需指定do_xcom_push=True - 这是BaseOperator 的默认值（参见source code）

如果没有向 Xcom 推送任何内容，则意味着函数 invoke_cloud_function 不会返回任何内容。