Воздушный поток: оператор Bash не дает результатов

Через Airflow, мы пытаемся выполнить приведенный ниже код, этот скрипт выполняется с кодом возврата 0, но без результата.

Ссылка: https://airflow.apache.org/tutorial.html

Взять тот же пример определения конвейера

t1 = BashOperator(
    task_id='print_date',
    bash_command='date',
    dag=dag)

Журнал показывает 0 код возврата, но вывод пуст

root@masbidw1.usa.corp.ad:/usr/airflow> airflow test tutorial print_date 2015-06-01
[2019-08-22 14:22:10,318] {__init__.py:45} INFO - Using executor SequentialExecutor
[2019-08-22 14:22:10,401] {models.py:189} INFO - Filling up the DagBag from /root/airflow/dags
[2019-08-22 14:22:10,552] {bash_operator.py:70} INFO - Tmp dir root location:
 /tmp
[2019-08-22 14:22:10,552] {bash_operator.py:80} INFO - Temporary script location: /tmp/airflowtmpFWK0XJ//tmp/airflowtmpFWK0XJ/print_dateYEnzSO
[2019-08-22 14:22:10,552] {bash_operator.py:88} INFO - Running command: date
[2019-08-22 14:22:10,557] {bash_operator.py:97} INFO - Output:
[2019-08-22 14:22:10,561] {bash_operator.py:101} INFO - Thu Aug 22 14:22:10 EDT 2019
[2019-08-22 14:22:10,561] {bash_operator.py:105} INFO - Command exited with return code 0

0 ответов

Другие вопросы по тегам