Can you provide a dag (as simplified as possible) which we can use to
reproduce this error?

On Thu, Dec 9, 2021 at 8:45 AM Anthony Joyce <[email protected]>
wrote:

> 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
>
>

Reply via email to