So i have been dealing with this issue for a while now without any light…
I have a DAG that queries data from BigQuery, and depending on the results some Dynamic Task Mappings are created to insert an entry in another BigQuery table using BigQueryInsertJobOperator…