A complete solution for open data platforms, enterprise data catalogs, data lakes and data management. Open source, mature, fully-featured and production ready.

DataHub

:wave:  We're seeing some new errors from the Airflow lineage backend, using Airflow 2.2.2,  originating from<https://github.com/linkedin/datahub/blob/f1045f817cb4300962dea6b41a6254f1f515fa57/metadata-ingestion/src/datahub_provider/_lineage_core.py#L142| this line> for DAGs where we set some value in the `params` -<https://github.com/apache/airflow/blob/43e84ccb8c909ad78862a9411ab72dbac6c7169c/airflow/models/dag.py#L347|dict >of the DAG. There seems to have been some change to how that argument is handled internally. I'm trying to look into it.

Seems to be a problem with tasks utilizing the `params` argument as well

So a very ugly fix seems to be to cast the `params` - dict to a `airflow.models.params.ParamsDict` for the dag, the tasks in `dag.task_dict` as well as the operator.

But I'm sure that's not very backwards compatible.

Hi <@U01AFJB5M9C>,
We are looking into this and will get back!