Mitch
06/12/2024, 2:04 AM.serve
and invoked using run_deployment
. For my example here below, if I set a breakpoint within the function using the @flow
decorator it will not stop execution but if I put a breakpoint in the function without a @flow
or @task
decorator it will stop execution and show me all the variables that I would expect. What is the recommended design pattern that we should use. If we use pdb we have to hardcode breakpoints, but if we use the vscode debugger we have to create an anti-pattern by wrapping functions with a flow that calls that function...
def tester():
context = FlowRunContext.get()
return context
@flow(log_prints=True, on_cancellation=[cancel_subflows])
async def base():
context = tester()
current_flow_run_id = context.flow_run.id
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.
Powered by