Airflow Summit 2025 is coming October 07-09. Register now for early bird ticket!

tests.system.openlineage.transport.variable¶

Attributes¶

log

Classes¶

VariableTransport

This transport sends OpenLineage events to Variables.

Module Contents¶

tests.system.openlineage.transport.variable.log[source]¶
class tests.system.openlineage.transport.variable.VariableTransport(config)[source]¶

Bases: openlineage.client.transport.Transport

This transport sends OpenLineage events to Variables.

Key schema is <DAG_ID>.<TASK_ID>.event.<EVENT_TYPE>. It’s made to be used in system tests, stored data read by OpenLineageTestOperator.

kind = 'variable'[source]¶
emit(event)[source]¶

Was this entry helpful?