XComs 在 composer-1.17.1-airflow-2.1.2 的 Xcom 部分不可见
XComs Not visible in Xcom Section in composer-1.17.1-airflow-2.1.2
我在我的 airflow DAG 中创建了一个任务，returns 一些值并且该值应该在 xcom 部分的 airflow 中可见，但它不是。
我已经设置 do_xcom_push = True
但它仍然不会显示。
在此之前我使用的是 Airflow 2.0.0，同样的任务用于将返回值推送到 xcom，但在 Airflow 2.1.2 中它没有发生。
我不明白我错过了什么。
这是气流任务的片段：
task = python_operator.PythonOperator(task_id="invoke_cf",python_callable=invoke_cloud_function,do_xcom_push=True)
默认情况下，PythonOperator 将可调用的 python 中的 return 值推送到 Xcom。无需指定 do_xcom_push=True - 这是默认值 BaseOperator（参见 source code）
如果没有任何东西被推送到 Xcom，这意味着函数 invoke_cloud_function 没有 return 任何东西。
我在我的 airflow DAG 中创建了一个任务，returns 一些值并且该值应该在 xcom 部分的 airflow 中可见，但它不是。 我已经设置 do_xcom_push = True 但它仍然不会显示。 在此之前我使用的是 Airflow 2.0.0，同样的任务用于将返回值推送到 xcom，但在 Airflow 2.1.2 中它没有发生。 我不明白我错过了什么。 这是气流任务的片段：
task = python_operator.PythonOperator(task_id="invoke_cf",python_callable=invoke_cloud_function,do_xcom_push=True)
PythonOperator 将可调用的 python 中的 return 值推送到 Xcom。无需指定 do_xcom_push=True - 这是默认值 BaseOperator（参见 source code）
如果没有任何东西被推送到 Xcom，这意味着函数 invoke_cloud_function 没有 return 任何东西。