OpenLineage Macros¶
Invoke as a jinja template, e.g.
Lineage run id¶
PythonOperator(
task_id="render_template",
python_callable=my_task_function,
op_args=[
"{{ macros.OpenLineageProviderPlugin.lineage_run_id(task_instance) }}"
], # lineage_run_id macro invoked
provide_context=False,
dag=dag,
)
Lineage parent id¶
PythonOperator(
task_id="render_template",
python_callable=my_task_function,
op_args=[
"{{ macros.OpenLineageProviderPlugin.lineage_parent_id(run_id, task_instance) }}"
], # macro invoked
provide_context=False,
dag=dag,
)