Hello All,
I want to one sqlalchemy engine through the flow, to avoid code duplicaton. My simple solution was to make a task which returns sqlalchemy engine object as result. It works when executing it locally, but returns error when executing it on server( cannot pickle local_object ).
Is there a solution to this problem or is there a best practice how to share connection in a flow?
Thanks!