CI-1235: Add workflow debugging feature

cirro/__init__.py

@@ -1,6 +1,7 @@
 import cirro.file_utils  # noqa
 from cirro.cirro_client import CirroApi
 from cirro.sdk.dataset import DataPortalDataset
+from cirro.sdk.file import DataPortalFile
 from cirro.sdk.login import DataPortalLogin
 from cirro.sdk.portal import DataPortal
 from cirro.sdk.process import DataPortalProcess
@@ -14,6 +15,7 @@
     'DataPortalProcess',
     'DataPortalDataset',
     'DataPortalReference',
+    'DataPortalFile',
     'CirroApi',
     'file_utils'
 ]

cirro/cli/__init__.py

@@ -1,6 +1,7 @@
 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.debug import run_debug
 
 __all__ = [
     'run_ingest',
@@ -11,4 +12,5 @@
     'run_validate_folder',
     'run_list_projects',
     'run_list_files',
+    'run_debug',
 ]

cirro/cli/cli.py

@@ -7,6 +7,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.debug import run_debug
 from cirro.cli.interactive.utils import InputError
 
 
@@ -142,6 +143,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()

cirro/cli/controller.py

@@ -9,12 +9,13 @@
 from cirro.cirro_client import CirroApi
 from cirro.cli.interactive.auth_args import gather_auth_config
 from cirro.cli.interactive.create_pipeline_config import gather_create_pipeline_config_arguments
-from cirro.cli.interactive.download_args import gather_download_arguments, ask_dataset_files
-from cirro.cli.interactive.download_args import gather_download_arguments_dataset
+from cirro.cli.interactive.download_args import gather_download_arguments, ask_dataset_files, \
+    gather_download_arguments_dataset
 from cirro.cli.interactive.list_dataset_args import gather_list_arguments
 from cirro.cli.interactive.upload_args import gather_upload_arguments
 from cirro.cli.interactive.upload_reference_args import gather_reference_upload_arguments
-from cirro.cli.interactive.utils import get_id_from_name, get_item_from_name_or_id, InputError, validate_files
+from cirro.cli.interactive.utils import get_id_from_name, get_item_from_name_or_id, InputError, \
+    validate_files
 from cirro.cli.interactive.validate_args import gather_validate_arguments, gather_validate_arguments_dataset
 from cirro.cli.models import ListArguments, UploadArguments, DownloadArguments, CreatePipelineConfigArguments, \
     UploadReferenceArguments, ValidateArguments, ListFilesArguments