dolfinus commented on PR #51164:
URL: https://github.com/apache/airflow/pull/51164#issuecomment-2919889759
After upgrading to OpenLineage Airflow provider 2.3.0 I don't see
`weight_rule` field:
```json
{
"eventTime": "2025-05-29T16:08:29.343335+00:00",
"eventType": "COMPLETE",
"inputs": [],
"job": {
"facets": {
"jobType": {
"_producer":
"https://github.com/apache/airflow/tree/providers-openlineage/2.3.0";,
"_schemaURL":
"https://openlineage.io/spec/facets/2-0-3/JobTypeJobFacet.json#/$defs/JobTypeJobFacet";,
"integration": "AIRFLOW",
"jobType": "TASK",
"processingType": "BATCH"
}
},
"name": "my_awesome_dag.load",
"namespace": "http://localhost:8080";
},
"outputs": [],
"producer":
"https://github.com/apache/airflow/tree/providers-openlineage/2.3.0";,
"run": {
"facets": {
"airflow": {
"_producer":
"https://github.com/apache/airflow/tree/providers-openlineage/2.3.0";,
"_schemaURL":
"https://openlineage.io/spec/2-0-2/OpenLineage.json#/$defs/RunFacet";,
"dag": {
"dag_id": "my_awesome_dag",
"fileloc": "/opt/airflow/dags/my_awesome_dag.py",
"owner": "airflow",
"owner_links": {},
"start_date": "2021-01-01T00:00:00+00:00",
"tags": "['example']",
"timetable": {}
},
"dagRun": {
"conf": {},
"dag_id": "my_awesome_dag",
"data_interval_end": "2025-05-29T16:08:14.367000+00:00",
"data_interval_start":
"2025-05-29T16:08:14.367000+00:00",
"logical_date": "2025-05-29T16:08:14.367000+00:00",
"run_after": "2025-05-29T16:08:14.367000+00:00",
"run_id": "manual__2025-05-29T16:08:16.335848+00:00",
"run_type": "manual",
"start_date": "2025-05-29T16:08:17.997784+00:00"
},
"task": {
"depends_on_past": false,
"downstream_task_ids": "[]",
"executor_config": {},
"ignore_first_depends_on_past": false,
"inlets": "[]",
"mapped": false,
"multiple_outputs": false,
"operator_class": "_PythonDecoratedOperator",
"operator_class_path":
"airflow.providers.standard.decorators.python._PythonDecoratedOperator",
"outlets": "[{'uri':
'postgres://postgres:5432/airflow/schema/table', 'extra': {}}]",
"owner": "airflow",
"priority_weight": 1,
"queue": "default",
"retries": 0,
"retry_exponential_backoff": false,
"task_id": "load",
"trigger_rule": "all_success",
"upstream_task_ids": "['transform']",
"wait_for_downstream": false,
"wait_for_past_depends_before_skipping": false
},
"taskInstance": {
"dag_bundle_name": "dags-folder",
"try_number": 1
},
"taskUuid": "01971ccd-1f1f-71e2-8b3e-b436345e63e0"
},
"parent": {
"_producer":
"https://github.com/apache/airflow/tree/providers-openlineage/2.3.0";,
"_schemaURL":
"https://openlineage.io/spec/facets/1-1-0/ParentRunFacet.json#/$defs/ParentRunFacet";,
"job": {
"name": "my_awesome_dag",
"namespace": "http://localhost:8080";
},
"root": {
"job": {
"name": "my_awesome_dag",
"namespace": "http://localhost:8080";
},
"run": {
"runId": "01971ccd-1f1f-7103-8eb9-3418c004be17"
}
},
"run": {
"runId": "01971ccd-1f1f-7103-8eb9-3418c004be17"
}
},
"processing_engine": {
"_producer":
"https://github.com/apache/airflow/tree/providers-openlineage/2.3.0";,
"_schemaURL":
"https://openlineage.io/spec/facets/1-1-1/ProcessingEngineRunFacet.json#/$defs/ProcessingEngineRunFacet";,
"name": "Airflow",
"openlineageAdapterVersion": "2.3.0",
"version": "3.0.1"
},
"unknownSourceAttribute": {
"_producer":
"https://github.com/apache/airflow/tree/providers-openlineage/2.3.0";,
"_schemaURL":
"https://openlineage.io/spec/2-0-2/OpenLineage.json#/$defs/RunFacet";,
"unknownItems": [
{
"name": "_PythonDecoratedOperator",
"properties": {
"depends_on_past": false,
"downstream_task_ids": "[]",
"executor_config": {},
"ignore_first_depends_on_past": false,
"inlets": "[]",
"mapped": false,
"multiple_outputs": false,
"operator_class": "_PythonDecoratedOperator",
"operator_class_path":
"airflow.providers.standard.decorators.python._PythonDecoratedOperator",
"outlets": "[{'uri':
'postgres://postgres:5432/airflow/schema/table', 'extra': {}}]",
"owner": "airflow",
"priority_weight": 1,
"queue": "default",
"retries": 0,
"retry_exponential_backoff": false,
"task_id": "load",
"trigger_rule": "all_success",
"upstream_task_ids": "['transform']",
"wait_for_downstream": false,
"wait_for_past_depends_before_skipping": false
},
"type": "operator"
}
]
}
},
"runId": "01971ccd-1f1f-71e2-8b3e-b436345e63e0"
},
"schemaURL":
"https://openlineage.io/spec/2-0-2/OpenLineage.json#/$defs/RunEvent";
}
```
Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
