tailg8nj commented on issue #63281: URL: https://github.com/apache/airflow/issues/63281#issuecomment-4916089591
How do we intend to offer opentelmetery vendors a way to propagate information across tasks via context_carriers? My open telemetry Distro leverages tracestate / baggage. The task span is created from the dag run context and not from the previous task context https://github.com/apache/airflow/blob/83edc67794b0e33233c6d4cdca8300e66b345939/airflow-core/src/airflow/api_fastapi/execution_api/routes/task_instances.py#L568 Because the dag_run.context_carrier is not exposed at the task level, I have no way to inject or propagate info to downstream tasks. Ideally a task should be able to inject information into the ti.context_carrier and have it be extracted for dependent tasks. -- 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]
