Traces Configuration
Airflow can be set up to send traces in OpenTelemetry.
Setup - OpenTelemetry
To use OpenTelemetry you must first install the required packages:
pip install 'apache-airflow[otel]'
Add the following lines to your configuration file e.g. airflow.cfg
[traces]
otel_on = True
otel_host = localhost
otel_port = 8889
otel_application = airflow
otel_ssl_active = False
otel_task_log_event = True
Note
The following config keys have been deprecated and will be removed in the future
[traces] otel_host = localhost otel_port = 8889 otel_debugging_on = False otel_service = Airflow otel_ssl_active = False
The OpenTelemetry SDK should be configured using standard OpenTelemetry environment variables
such as OTEL_EXPORTER_OTLP_ENDPOINT, OTEL_EXPORTER_OTLP_PROTOCOL, etc.
See the OpenTelemetry exporter protocol specification and SDK environment variable documentation for more information.
Adding Custom Spans in Tasks
DAG authors can instrument their tasks with custom spans using the trace object from
airflow.sdk.observability. This is a thin shim over the standard OpenTelemetry
opentelemetry.trace module, so all standard OpenTelemetry tracing APIs are available.
from airflow.sdk import task
from airflow.sdk.observability import trace
tracer = trace.get_tracer(__name__)
@task
def my_task():
with tracer.start_as_current_span("my_span") as span:
span.set_attribute("key", "value")
# ... task logic ...
Custom spans created this way are automatically nested as children of the Airflow-managed task span when tracing is enabled. When tracing is disabled, the no-op tracer provided by the OpenTelemetry API is used, so tasks run without any overhead.
Per-run trace controls (run conf)
A few reserved keys in a Dag run’s conf let you control tracing for that individual run.
They are read when the run is created (and when it is cleared), so set them when you trigger the
run — from the UI/API “Trigger with config” dialog, the airflow dags trigger --conf CLI, or
TriggerDagRunOperator(conf=...).
airflow/trace_sampledForce the head-sampling decision for this run.
truealways traces the run andfalsenever does, regardless of the configured sampler; omit the key to let the sampler decide. Only an explicit boolean is honored.airflow/task_span_detail_levelTo enable detailed spans, set detail level greater than 1. This is intended as a debug-supporting feature as such it is subject to change or removal at any time.
airflow/dagrun_parent_trace_contextEmbed this run in an external trace instead of it being a root trace. Supply a W3C
traceparentstring (optionally a mapping withtraceparentandtracestate) captured from the system that triggered the run — an upstream orchestrator, event pipeline, CI job, or another Airflow deployment. The whole run (thedag_runspan and all task/worker spans) then lives inside that trace, and parent-based samplers inherit the external sampling decision. When the key is absent (default), the run is a root trace. A missing or malformed value is ignored (the run stays a root) rather than failing run creation.{"airflow/dagrun_parent_trace_context": "00-4bf92f3577b34da6a3ce929d0e0e4736-00f067aa0ba902b7-01"}
Enable Https
To establish an HTTPS connection to the OpenTelemetry collector
You need to configure the SSL certificate and key within the OpenTelemetry collector’s config.yml file.
receivers:
otlp:
protocols:
http:
endpoint: 0.0.0.0:4318
tls:
cert_file: "/path/to/cert/cert.crt"
key_file: "/path/to/key/key.pem"