The karbor.services.protection.flows.protect Module¶

class karbor.services.protection.flows.protect.CompleteProtectTask(name=None, provides=None, requires=None, auto_extract=True, rebind=None, inject=None, ignore_list=None, revert_rebind=None, revert_requires=None)¶

Bases: taskflow.task.Task

execute(checkpoint)¶

class karbor.services.protection.flows.protect.InitiateProtectTask(name=None, provides=None, requires=None, auto_extract=True, rebind=None, inject=None, ignore_list=None, revert_rebind=None, revert_requires=None)¶

Bases: taskflow.task.Task

execute(checkpoint, *args, **kwargs)¶

revert(checkpoint, *args, **kwargs)¶

karbor.services.protection.flows.protect.get_flow(context, protectable_registry, workflow_engine, plan, provider, checkpoint)¶