I have a DockerOperator working but airflow does not show any logging statement of my DockerOperator like it did for PythonOperator or BashOperator when I run it with "airflow test". However I can see the logging statements the same task is run. How would I made the logger visible for "airflow test" as well?
Adding the following to my execution module displayed the logs in the DockerOperator for me.
import logging
import sys
logging.basicConfig(stream=sys.stdout, level=logging.INFO)
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With