(
operation: str, pipeline_name: str, pipelines_dir: str, verbosity: int, **command_kwargs: Any
)
| 457 | |
| 458 | |
| 459 | def pipeline_command_wrapper( |
| 460 | operation: str, pipeline_name: str, pipelines_dir: str, verbosity: int, **command_kwargs: Any |
| 461 | ) -> None: |
| 462 | try: |
| 463 | pipeline_command(operation, pipeline_name, pipelines_dir, verbosity, **command_kwargs) |
| 464 | except CannotRestorePipelineException as ex: |
| 465 | fmt.secho(str(ex), err=True, fg="red") |
| 466 | fmt.secho( |
| 467 | "Try command %s to restore the pipeline state from destination" |
| 468 | % fmt.bold(fmt.cli_cmd(f"pipeline {pipeline_name} sync")) |
| 469 | ) |
| 470 | raise CliCommandException(error_code=-2) |
nothing calls this directly
no test coverage detected