tests.system.openlineage.transport.variable

VariableTransport

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

模块内容

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

基类: openlineage.client.transport.Transport

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

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

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

此条目有帮助吗?