tests.system.openlineage.transport.variable

模块内容

VariableTransport

此传输将 OpenLineage 事件发送到变量。

class tests.system.openlineage.transport.variable.VariableTransport[源代码]

基类: openlineage.client.transport.Transport

此传输将 OpenLineage 事件发送到变量。

键的模式为 <DAG_ID>.<TASK_ID>.event.<EVENT_TYPE>。它用于系统测试,存储的数据由 OpenLineageTestOperator 读取。

kind = 'variable'[源代码]
emit(event)[源代码]

此条目是否有帮助?