Kiley Roberson
09/18/2023, 9:24 PMasync def my_subflow(id: str):
def run_logic():
product_logic(id)
loop = asyncio.get_running_loop()
await loop.run_in_executor(None, run_logic)
However - I am getting this error when trying to set up the logger:
Flow run encountered an exception. MissingContextError: There is no active flow or task run context
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!