Я отправляю задание потока данных через airflow v1.10.0 (установлен на локальном компьютере)
Задание отправляется и успешно выполняется, но поток воздуха не выходит в зависимости от состояния задания.
Может ли кто-нибудь помочь в решении этой проблемы
Кодовый блок для этого же доступен в Запуск потока данных с использованием воздушного потока
Ниже приведено сообщение журнала
[2018-10-29 16:47:48,313] {gcp_dataflow_hook.py:128} WARNING - INFO:root:Job
2018-10-29_04_17_36-2871901639034996418 is in state JOB_STATE_RUNNING
[2018-10-29 16:47:48,313] {gcp_dataflow_hook.py:128} WARNING - INFO:root:2018-
10-29T11:17:42.201Z: JOB_MESSAGE_DEBUG: Tearing down pending resources...
[2018-10-29 16:47:48,313] {gcp_dataflow_hook.py:128} WARNING - INFO:root:Job
2018-10-29_04_17_36-2871901639034996418 is in state JOB_STATE_DONE
[2018-10-29 16:47:48,314] {gcp_api_base_hook.py:90} INFO - Getting connection
using a JSON key file.
[2018-10-29 16:47:48,319] {discovery.py:267} INFO - URL being requested: GET
https://www.googleapis.com/discovery/v1/apis/dataflow/v1b3/rest
[2018-10-29 16:47:52,744] {discovery.py:866} INFO - URL being requested: GET
https://dataflow.googleapis.com/v1b3/projects/dataflow-219809/locations/us-
central1/jobs?alt=json
[2018-10-29 16:47:55,060] {gcp_dataflow_hook.py:77} INFO - Google Cloud
DataFlow job not available yet..