Skip to content

Commit

Permalink
Fix OpenLineage provide plugin examples (#39029)
Browse files Browse the repository at this point in the history
  • Loading branch information
dolfinus committed Apr 16, 2024
1 parent 95e2611 commit 09e938a
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions docs/apache-airflow-providers-openlineage/macros.rst
Original file line number Diff line number Diff line change
Expand Up @@ -42,9 +42,9 @@ For example, ``SparkSubmitOperator`` can be set up like this:
application="/script.py",
conf={
# separated components
"spark.openlineage.parentJobNamespace": "{{ macros.OpenLineagePlugin.lineage_job_namespace() }}",
"spark.openlineage.parentJobName": "{{ macros.OpenLineagePlugin.lineage_job_name(task_instance) }}",
"spark.openlineage.parentRunId": "{{ macros.OpenLineagePlugin.lineage_run_id(task_instance) }}",
"spark.openlineage.parentJobNamespace": "{{ macros.OpenLineageProviderPlugin.lineage_job_namespace() }}",
"spark.openlineage.parentJobName": "{{ macros.OpenLineageProviderPlugin.lineage_job_name(task_instance) }}",
"spark.openlineage.parentRunId": "{{ macros.OpenLineageProviderPlugin.lineage_run_id(task_instance) }}",
},
)
Expand Down

0 comments on commit 09e938a

Please sign in to comment.