airflow.providers.openlineage.api.core¶

Core OpenLineage primitives: runtime-state probe and raw-event emission.

Functions¶

`is_openlineage_active`()	Return `True` when OpenLineage is enabled and its listener is available.
`emit`(event)	Emit a pre-built OpenLineage event through the provider's listener.

Module Contents¶

airflow.providers.openlineage.api.core.is_openlineage_active()[source]¶

Return True when OpenLineage is enabled and its listener is available.

Useful to short-circuit work that only makes sense when OpenLineage is going to actually emit events (for example, fetching extra metadata from a warehouse solely to attach it to lineage facets).

airflow.providers.openlineage.api.core.emit(event)[source]¶

Emit a pre-built OpenLineage event through the provider’s listener.