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)¶