Команда Python3, которая всегда работает в Airflow - PullRequest
0 голосов
/ 20 декабря 2018

Я вызываю задачу, которая запускает команду python3.Я поместил оператор main is called в первую строку оператора if __name__ == '__main__':.Однако это утверждение никогда не выполняется.Как я могу быть уверен, что файл будет вызван, а все остальное уже было выполнено?По логам:

[2018-12-20 07:15:24,456] {bash_operator.py:87} INFO - Temporary script location: /tmp/airflowtmpah5gx32p/pscript_pclean_phlc9h6grzqdhm6sc0zrxjne_UdOgg0xdoblvr
[2018-12-20 07:15:24,456] {bash_operator.py:97} INFO - Running command: python3 /usr/local/airflow/rootfs/mopng_beneficiary_v2/scripts/pclean_phlc9h6grzqdhm6sc0zrxjne_UdOgg.py /usr/local/airflow/rootfs/mopng_beneficiary_v2/manual__2018-12-18T12:06:14+00:00/appended/euoEQHIwIQTe1wXtg46fFYok.csv /usr/local/airflow/rootfs/mopng_beneficiary_v2/external/5Feb18_master_ujjwala_latlong_dist_dno_so_v7.csv /usr/local/airflow/rootfs/mopng_beneficiary_v2/external/ppac_master_v3_mmi_enriched_with_sanity_check.csv /usr/local/airflow/rootfs/mopng_beneficiary_v2/manual__2018-12-18T12:06:14+00:00/pcleaned/Qc01sB1s1WBLhljjIzt2S0Ex.csv
[2018-12-20 07:15:24,467] {bash_operator.py:106} INFO - Output:
...