# #airflow #google-cloud-composer
Вопрос:
Я создал задачу в своей группе поддержки воздушного потока, которая возвращает некоторое значение, и это значение должно быть видно в разделе xcom о воздушном потоке, но его нет. Я установил do_xcom_push = True, но все равно он не будет отображаться. До этого я использовал Airflow 2.0.0, и та же задача использовалась для передачи возвращаемого значения в xcom, но в Airflow 2.1.2 этого не происходит. Я не понимаю, чего мне не хватает. Вот фрагмент задачи воздушного потока:
задача = python_operator.PythonОператор(task_id=»invoke_cf»,python_callable=функция invoke_cloud_function,do_xcom_push=True)
Комментарии:
1. Поделитесь кодом функции invoke_cloud_function
Ответ №1:
PythonOperator по умолчанию возвращает возвращаемое значение из вызываемого python в Xcom. Нет необходимости указывать do_xcom_push=True — это значение по умолчанию BaseOperator (см. Исходный код).
если в Xcom ничего не передается, это означает, что функция invoke_cloud_function ничего не возвращает.
Комментарии:
1. Понятно , я использовал функцию python для вызова облачной функции в gcp, и этот CF вернул значение, и я подумал, что этого будет достаточно. Спасибо за ваше время @Elad