amoghrajesh commented on issue #57336: URL: https://github.com/apache/airflow/issues/57336#issuecomment-3455021968
Looking at your stacktrace, I see this error: When the flow reached this ```python local_filesystem.py:228 in _create_connection ``` This starts: ```shell script <string>:4 in __init__ ↓ sqlalchemy/orm/state.py:476 in _initialize_instance ↓ sqlalchemy/event/attr.py:346 in __call__ ↓ sqlalchemy/orm/mapper.py:3716 in _event_on_init ↓ sqlalchemy/orm/mapper.py:1941 in _check_configure sqlalchemy/orm/mapper.py:3527 in _configure_registries ↓ sqlalchemy/orm/mapper.py:3566 in _do_configure_registries sqlalchemy/orm/mapper.py:1958 in _post_configure_properties ↓ sqlalchemy/orm/relationships.py:2150 in do_init ↓ sqlalchemy/orm/relationships.py:2245 in _process_dependent_arguments sqlalchemy/orm/clsregistry.py:397 in _resolve_name ↓ KeyError: 'DagCode' ``` The case seems to be that the worker environment is incomplete. My hypothesis: In your Celery worker, some initialization code (in your fork) imports `DagVersion` without importing `DagCode`, causing the mapper configuration to fail. @adrian-edbert TLDR, could you check what happens outside your fork so you can rule out if your changes cause this? -- 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]
