JASNOTJAZZ commented on issue #47297: URL: https://github.com/apache/airflow/issues/47297#issuecomment-2700891791
How to Reproduce the Issue Define a DAG with a TaskGroup containing BigQueryInsertJobOperator tasks. Execute the DAG and check the BigQuery job metadata. Observe that the labels "airflow-dag" and "airflow-task" are missing. Possible Cause The operator retrieves dag_id and task_id from the task instance, but TaskGroups modify task IDs by prefixing them with the group name (e.g., taskgroup_1.insert_job_1). The traceability logic may not be properly handling this case when constructing labels. Solution Approach Modify BigQueryInsertJobOperator to handle TaskGroups properly when assigning traceability labels. Ensure the full task ID (including TaskGroup name) is included in labels. Test the fix using a DAG with a TaskGroup and verify that labels appear in BigQuery job metadata. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
