Anna Gerlich
02/07/2023, 11:37 AMCole Murray
02/07/2023, 6:11 PMmodule, method = module_name.rsplit('.', 1)
mod = importlib.import_module(module)
workflow_flow = getattr(mod, method)
flow_filepath = getattr(mod, "__file__", None)
print(f"Flow filepath: {flow_filepath}")
deployment = Deployment.build_from_flow(
flow=workflow_flow,
name=schedule.id,
version=1,
entrypoint=f"{flow_filepath}:{workflow_flow.fn.__name__}",
work_queue_name="default",
parameters={},
schedule=deployment_schedule,
)
deployment.apply()
Anna Gerlich
02/08/2023, 2:52 PM