The karbor.services.protection.flows.worker Module

class karbor.services.protection.flows.worker.Worker(engine_path=None)

Bases: object

flow_outputs(flow_engine, target=None)

get_flow(context, operation_type, checkpoint, provider, **kwargs)

run_flow(flow_engine)