Hi community, I have the following simple flow. This consists of only one load task.

@flow

def flow():

db_connection = db_connection()

with db_connection() as cursor:

load(cursor)

However, when I run it I get the error: Flow run encountered an exception. ProgrammingError: no results to fetch I have already found out that it is probably the cursor object which I pass to the task. Is there a way to make a database connection and then pass it to the tasks? thanks :)

You can’t pickle / pass db connections