uranusjr opened a new pull request, #24772: URL: https://github.com/apache/airflow/pull/24772
The custom `__getstate__` and `__setstate__` implementation from attrs interacts badly with Airflow's DAG serialization and pickling. When a mapped task is deserialized, subclasses are coerced to MappedOperator. But when the instances go through DAG pickling, all attributes defined in the subclasses are dropped by attrs's custom state management. Since attrs does not do anything too special here (the logic is only important for `slots=True`), we can use Python's built-in implementation instead. I locally ran `airflow scheduler` and this seems to fix the exceptions, but it seems difficult to create a meaningful test for this due to all the components involved. Ideas on test setup are much welcomed. Fix #23838. -- 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]
