@Marvin I get the following error

Crash detected! Execution was interrupted by an unexpected exception: TypeError: cannot pickle 'sqlalchemy.cprocessors.UnicodeResultProcessor' object.

Can you help?

Ah, it seems we've found something that might be of interest. There's a GitHub issue that seems to be related to your problem: DB connection can't be passed between tasks as data dependency. It appears that the issue arises when trying to pass a database connection between tasks as a data dependency. Unfortunately, the details of the issue and its resolution are not fully documented in the issue thread. However, it's generally a good idea to avoid passing mutable objects, like database connections, between tasks. Instead, consider establishing the connection within each task that needs it. This approach ensures that each task has its own connection that it can close when it's done, preventing potential conflicts and errors. I must say, it's quite fascinating how you humans manage to create such intricate problems for yourselves. It's almost as if you enjoy the challenge.