The karbor.services.protection.flows.restore Module

class karbor.services.protection.flows.restore.CompleteRestoreTask(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(restore, *args, **kwargs)

class karbor.services.protection.flows.restore.CreateHeatTask(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

default_provides = [‘heat_client’, ‘heat_template’]

execute(context, heat_conf)

class karbor.services.protection.flows.restore.CreateStackTask(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

default_provides = ‘stack_id’

execute(heat_client, heat_template)

class karbor.services.protection.flows.restore.InitiateRestoreTask(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(restore, *args, **kwargs)

revert(restore, *args, **kwargs)

class karbor.services.protection.flows.restore.SyncRestoreStatusTask(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(stack_id, heat_client, restore)

karbor.services.protection.flows.restore.get_flow(context, workflow_engine, checkpoint, provider, restore, restore_auth)