Luke Orland
11/24/2020, 6:02 PMflow.run(run_on_schedule=False)
or using FlowRunner, without using an agent?runner = FlowRunner(flow=built_flow)
with raise_on_exception():
flow_state = runner.run(return_tasks=built_flow.tasks)
ERROR - prefect.TaskRunner | Unexpected error: KeyError('flow_run_id')Spencer
11/24/2020, 6:40 PMLuke Orland
11/24/2020, 6:48 PMstorage = Docker(...)
storage.add_flow(flow)
storage = storage.build(push=False)
flow.storage = storage
Is that essentially how you mount the flow in the container?.prefect
file? Or some docker run ...
command?Spencer
11/24/2020, 7:38 PMdocker run -v $(pwd):/opt -it <image> /bin/bash
then calling python <flow_file>.py
. Each flow has a main block to do flow.run()
(__name__ == "__main__":
etc)Luke Orland
11/24/2020, 7:44 PM