Проект Apache Airflow, по-видимому, заставил TriggerDagRunOperator conf разрешить только JSON. Это отличается от того, что было раньше, когда мне разрешалось передавать экземпляры классов без какой-либо специальной обработки.
conf
https://github.com/apache/airflow/blob/master/airflow/operators/dagrun_operator.py#L94
https://github.com/apache/airflow/blob/master/airflow/api/common/experimental/trigger_dag.py#L65
Это 2 фрагмента, которые обеспечивают это.
Кто-нибудь также сталкивался с этой проблемой? Если да, то как вы обходите это ограничение?
В настоящее время я обхожу эту проблему, создавая пользовательский оператор на основе оператора перед этими изменениями.