Hi Team, I'm having issues on data emission for our Airflow DAGs with schedule interval

None

or

1:00:00

. Other DAGs are working fine. Any idea on this? Thanks. Please see error stacktrace. cc: @hallowed-intern-9191

File "/usr/local/lib/python3.7/site-packages/***/serialization/serialized_objects.py", line 830, in serialize_dag
    serialize_dag["tasks"] = [cls._serialize(task) for _, task in dag.task_dict.items()]
  File "/usr/local/lib/python3.7/site-packages/***/serialization/serialized_objects.py", line 830, in <listcomp>
    serialize_dag["tasks"] = [cls._serialize(task) for _, task in dag.task_dict.items()]
  File "/usr/local/lib/python3.7/site-packages/***/serialization/serialized_objects.py", line 308, in _serialize
    return SerializedBaseOperator.serialize_operator(var)
  File "/usr/local/lib/python3.7/site-packages/***/serialization/serialized_objects.py", line 578, in serialize_operator
    serialize_op['params'] = cls._serialize_params_dict(op.params)
  File "/usr/local/lib/python3.7/site-packages/***/serialization/serialized_objects.py", line 451, in _serialize_params_dict
    if f'{v.__module__}.{v.__class__.__name__}' == '***.models.param.Param':
AttributeError: 'int' object has no attribute '__module__'

@brief-cat-57352 Can you upgrade your Airflow plugin version? This was a known issue which we fixed already.

got it. will upgrade. thanks for the feedback @dazzling-judge-80093

Do you see the same error there?

this is encountered for Airflow DAGs with schedule interval of

None

and

1:00:00