Hello fellow users-
I have encountered an error which seems to be related to serialization:
Broken DAG: [/home/etl/airflow/dags/airflow_platypus_etl_dag.py] Traceback
(most recent call last): File
"/home/etl/anaconda3/lib/python3.8/site-packages/airflow/serialization/serialized_objects.py",
line 574, in serialize_operator serialize_op['params'] =
cls._serialize_params_dict(op.params) File
"/home/etl/anaconda3/lib/python3.8/site-packages/airflow/serialization/serialized_objects.py",
line 447, in _serialize_params_dict if
f'{v.__module__}.{v.__class__.__name__}' == 'airflow.models.param.Param':
AttributeError: 'str' object has no attribute '__module__' During handling of
the above exception, another exception occurred: Traceback (most recent call
last): File
"/home/etl/anaconda3/lib/python3.8/site-packages/airflow/serialization/serialized_objects.py",
line 935, in to_dict json_dict = {"__version": cls.SERIALIZER_VERSION, "dag":
cls.serialize_dag(var)} File
"/home/etl/anaconda3/lib/python3.8/site-packages/airflow/serialization/serialized_objects.py",
line 847, in serialize_dag raise SerializationError(f'Failed to serialize DAG
{dag.dag_id!r}: {e}') airflow.exceptions.SerializationError: Failed to
serialize DAG 'Platypus_ETL': 'str' object has no attribute ‘__module__'
I have spent some time trying to figure out what is going on but to no avail.
Anyone have any insight on an error like this? I am on Airflow release 2.2.2
and I am using the default packages constraints.
Thanks all,
Anthony
