tests.system.openlineage.transport.variable

Module Contents

Classes

VariableTransport

This transport sends OpenLineage events to Variables.
class tests.system.openlineage.transport.variable.VariableTransport[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?