CY-901 cfy local: add executions list and get (#897)

* cfy local: add `executions list`

* cfy local: add `executions get`

* BASE_EXECUTION_COLUMNS

Author: tehasdf

cloudify_cli/commands/executions.py

@@ -34,15 +34,15 @@
     'NOTE: Executions currently in a "canceling/force-canceling" status '
     'may take a while to change into "cancelled"')
 
-FULL_EXECUTION_COLUMNS = ['id', 'workflow_id', 'status_display', 'is_dry_run',
-                          'deployment_id', 'created_at', 'ended_at',
-                          'error', 'visibility', 'tenant_name',
-                          'created_by', 'started_at', 'scheduled_for']
-MINIMAL_EXECUTION_COLUMNS = ['id', 'workflow_id', 'status_display',
-                             'is_dry_run',
-                             'deployment_id', 'created_at', 'started_at',
-                             'scheduled_for', 'visibility', 'tenant_name',
-                             'created_by']
+BASE_EXECUTION_COLUMNS = ['id', 'workflow_id', 'status_display']
+LOCAL_EXECUTION_COLUMNS = BASE_EXECUTION_COLUMNS + [
+    'blueprint_id', 'started_at', 'ended_at', 'error']
+FULL_EXECUTION_COLUMNS = BASE_EXECUTION_COLUMNS + [
+    'is_dry_run', 'deployment_id', 'created_at', 'ended_at', 'error',
+    'visibility', 'tenant_name', 'created_by', 'started_at', 'scheduled_for']
+MINIMAL_EXECUTION_COLUMNS = BASE_EXECUTION_COLUMNS + [
+    'is_dry_run', 'deployment_id', 'created_at', 'started_at', 'scheduled_for',
+    'visibility', 'tenant_name', 'created_by']
 EXECUTION_TABLE_LABELS = {'status_display': 'status'}
 
 
@@ -90,7 +90,7 @@ def manager_get(execution_id, logger, client, tenant_name):
 
 
 @cfy.command(name='list',
-             short_help='List deployment executions [manager only]')
+             short_help='List deployment executions')
 @cfy.options.deployment_id(required=False)
 @cfy.options.include_system_workflows
 @cfy.options.sort_by()
@@ -333,6 +333,46 @@ def manager_cancel(execution_id, force, kill, logger, client, tenant_name):
         "cfy executions get {0}".format(execution_id))
 
 
+@cfy.command(name='list',
+             short_help='List deployment executions')
+@cfy.options.blueprint_id(required=True)
+@cfy.options.common_options
+@cfy.pass_logger
+def local_list(blueprint_id, logger):
+    """Execute a workflow
+
+    `WORKFLOW_ID` is the id of the workflow to execute (e.g. `uninstall`)
+    """
+    env = local.load_env(blueprint_id)
+    executions = env.storage.get_executions()
+    print_data(LOCAL_EXECUTION_COLUMNS, executions, 'Executions:',
+               labels=EXECUTION_TABLE_LABELS)
+
+
+@cfy.command(name='get',
+             short_help='Retrieve execution information')
+@cfy.argument('execution-id')
+@cfy.options.blueprint_id(required=True)
+@cfy.options.common_options
+@cfy.pass_logger
+def local_get(execution_id, blueprint_id, logger):
+    """Retrieve information for a specific execution
+
+    `EXECUTION_ID` is the execution to get information on.
+    """
+    env = local.load_env(blueprint_id)
+    execution = env.storage.get_execution(execution_id)
+    if not execution:
+        raise CloudifyCliError('Execution {0} not found'.format(execution_id))
+    columns = LOCAL_EXECUTION_COLUMNS
+    if get_global_json_output():
+        columns += ['parameters']
+    print_single(LOCAL_EXECUTION_COLUMNS, execution, 'Execution:',
+                 labels=EXECUTION_TABLE_LABELS)
+    if not get_global_json_output():
+        print_details(execution['parameters'], 'Execution Parameters:')
+
+
 @cfy.command(name='start',
              short_help='Execute a workflow')
 @cfy.argument('workflow-id')

cloudify_cli/main.py

@@ -114,8 +114,6 @@ def _register_commands():
     deployments.deployments.add_command(deployments.manager_set_visibility)
 
     executions.executions.add_command(executions.manager_cancel)
-    executions.executions.add_command(executions.manager_list)
-    executions.executions.add_command(executions.manager_get)
 
     # Commands which should be both in manager and local context
     # But change depending on the context.
@@ -129,6 +127,8 @@ def _register_commands():
         deployments.deployments.add_command(deployments.manager_capabilities)
 
         executions.executions.add_command(executions.manager_start)
+        executions.executions.add_command(executions.manager_list)
+        executions.executions.add_command(executions.manager_get)
 
         blueprints.blueprints.add_command(blueprints.manager_list)
     else:
@@ -140,6 +140,8 @@ def _register_commands():
         deployments.deployments.add_command(deployments.local_outputs)
 
         executions.executions.add_command(executions.local_start)
+        executions.executions.add_command(executions.local_list)
+        executions.executions.add_command(executions.local_get)
 
         blueprints.blueprints.add_command(blueprints.local_list)