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)[source]¶
从 DBT Cloud 运行生成 OpenLineage 事件。
此函数检索有关 DBT Cloud 运行的信息，包括关联的作业、项目和执行详情。它会并行处理运行的产物，例如 manifest 和运行结果（适用于许多步骤）。然后它根据已执行的 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