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