`airflow.providers.dbt.cloud.utils.openlineage`¶

模块内容¶

从 DBT Cloud 运行生成 OpenLineage 事件。

airflow.providers.dbt.cloud.utils.openlineage.generate_openlineage_events_from_dbt_cloud_run(operator, task_instance)[源代码]¶

从 DBT Cloud 运行生成 OpenLineage 事件。

此函数检索有关 DBT Cloud 运行的信息，包括关联的作业、项目和执行详情。它并行处理运行的工件，例如清单和运行结果，以进行许多步骤。然后，它基于执行的 DBT 任务生成并发出 OpenLineage 事件。

参数

operator (airflow.providers.dbt.cloud.operators.dbt.DbtCloudRunJobOperator | airflow.providers.dbt.cloud.sensors.dbt.DbtCloudJobRunSensor) – 执行 DBT 任务的 DBT Cloud 操作符的实例。它应该已经有 run_id 和 dbt cloud hook。
task_instance (airflow.models.taskinstance.TaskInstance) – 当前执行的任务实例

返回

一个空的 OperatorLineage 对象，指示事件生成完成。

返回类型

airflow.providers.openlineage.extractors.OperatorLineage