Add workflow debugging feature

cirro/cli/__init__.py

@@ -1,6 +1,6 @@
 from cirro.cli.controller import run_ingest, run_download, run_configure, run_list_datasets
 from cirro.cli.controller import run_create_pipeline_config, run_validate_folder
-from cirro.cli.controller import run_list_projects, run_list_files
+from cirro.cli.controller import run_list_projects, run_list_files, run_debug
 
 __all__ = [
     'run_ingest',
@@ -11,4 +11,5 @@
     'run_validate_folder',
     'run_list_projects',
     'run_list_files',
+    'run_debug',
 ]

cirro/cli/cli.py

@@ -6,7 +6,7 @@
 
 from cirro.cli import run_create_pipeline_config, run_validate_folder
 from cirro.cli import run_ingest, run_download, run_configure, run_list_datasets
-from cirro.cli.controller import handle_error, run_upload_reference, run_list_projects, run_list_files
+from cirro.cli.controller import handle_error, run_upload_reference, run_list_projects, run_list_files, run_debug
 from cirro.cli.interactive.utils import InputError
 
 
@@ -142,6 +142,21 @@ def upload_reference(**kwargs):
     run_upload_reference(kwargs, interactive=kwargs.get('interactive'))
 
 
+@run.command(help='Debug a failed workflow execution', no_args_is_help=True)
+@click.option('--project',
+              help='Name or ID of the project',
+              default=None)
+@click.option('--dataset',
+              help='Name or ID of the dataset',
+              default=None)
+@click.option('-i', '--interactive',
+              help='Gather arguments interactively',
+              is_flag=True, default=False)
+def debug(**kwargs):
+    check_required_args(kwargs)
+    run_debug(kwargs, interactive=kwargs.get('interactive'))
+
+
 @run.command(help='Configure authentication')
 def configure():
     run_configure()