'how to fetch job_id in downstream task for BigQueryInsertJobOperator
how to fetch job_id of BigQueryInsertJobOperator. previously i was running few queries using BigQueryOperator and fetching its job_id in downstream task using xcom_pull which as used to fetch metadata from bq tables, but now in new airflow version BigQueryOperator are deprecated so want to use BigQueryInsertJobOperator. is there any way to achieve same with BigQueryInsertJobOperator.
Sources
This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.
Source: Stack Overflow
| Solution | Source |
|---|