Kiley Roberson09/18/2023, 9:24 PM
However - I am getting this error when trying to set up the logger:
async def my_subflow(id: str): def run_logic(): product_logic(id) loop = asyncio.get_running_loop() await loop.run_in_executor(None, run_logic)
So some needed context is being lost when I create the new thread. Im wondering if there is a different approach for how I can execute the logic as a non blocking routine or maybe some way I can set the needed context? Thanks!
Flow run encountered an exception. MissingContextError: There is no active flow or task run context