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?