Add missing cfy executions resume (#908)

Frontend for the client.executions.resume call

Author: tehasdf

cloudify_cli/cli/cfy.py

@@ -1015,6 +1015,13 @@ def __init__(self):
             help=helptexts.QUEUE_EXECUTIONS
         )
 
+        self.reset_operations = click.option(
+            '--reset-operations',
+            is_flag=True,
+            default=False,
+            help=helptexts.RESET_OPERATIONS
+        )
+
         self.schedule = click.option(
             '--schedule',
             cls=MutuallyExclusiveOption,

cloudify_cli/cli/helptexts.py

@@ -314,3 +314,5 @@
 
 WAIT_AFTER_FAIL = 'When a task fails, wait this many seconds for ' \
                   'already-running tasks to return'
+RESET_OPERATIONS = 'Reset operations in started state, so that they are '\
+                   'ran again unconditionally'

cloudify_cli/commands/executions.py

@@ -341,6 +341,34 @@ def manager_cancel(execution_id, force, kill, logger, client, tenant_name):
         "cfy executions get {0}".format(execution_id))
 
 
+@cfy.command(name='resume',
+             short_help='Resume a workflow execution [manager only]')
+@cfy.argument('execution-id')
+@cfy.options.common_options
+@cfy.options.reset_operations
+@cfy.options.tenant_name(required=False, resource_name_for_help='execution')
+@cfy.assert_manager_active()
+@cfy.pass_client()
+@cfy.pass_logger
+def manager_resume(execution_id, reset_operations, logger, client,
+                   tenant_name):
+    """Resume the execution of a workflow in a failed or cancelled state.
+
+    `EXECUTION_ID` is the ID of the execution to resume.
+    The workflow will run again, restoring the tasks graph from the storage,
+    and retrying failed tasks when necessary.
+    If reset-operations is passed, tasks that were started but didn't fail
+    will be retried as well.
+    """
+    utils.explicit_tenant_name_message(tenant_name, logger)
+    logger.info('Resuming execution {0}'.format(execution_id))
+    client.executions.resume(execution_id, force=reset_operations)
+    logger.info(
+        "A resume request for execution {0} has been sent. "
+        "To track the execution's status, use:\n"
+        "cfy executions get {0}".format(execution_id))
+
+
 @cfy.command(name='list',
              short_help='List deployment executions')
 @cfy.options.blueprint_id(required=True)

cloudify_cli/main.py

@@ -129,6 +129,7 @@ def _register_commands():
         executions.executions.add_command(executions.manager_get)
 
         blueprints.blueprints.add_command(blueprints.manager_list)
+        executions.executions.add_command(executions.manager_resume)
     else:
         _cfy.add_command(install.local)
         _cfy.add_command(uninstall.local)