Python operator is not being called in dynamic subdag in Airflow
I have created a subdag dynamically. Everything working properly, main_dag is running fine. Its PythonOperator function is being called. But Python callable in Subdag are not being called. Kindly help me. As I am new to Airflow, so got and merged this code from different sources. from airflow import DAG from airflow.operators.bash_operator import BashOperator from … Read more