| 2121 | from specify_cli.workflows.engine import RunState, WorkflowEngine |
| 2122 | |
| 2123 | class _ProbeStep(StepBase): |
| 2124 | type_key = "probe" |
| 2125 | |
| 2126 | def execute(self, config, context): |
| 2127 | status = StepStatus.COMPLETED |
| 2128 | if on_item is not None: |
| 2129 | override = on_item(context.item) |
| 2130 | if override is not None: |
| 2131 | status = override |
| 2132 | return StepResult(status=status, output={"seen": context.item}) |
| 2133 | |
| 2134 | engine = WorkflowEngine(project_root=tmp_path) |
| 2135 | context = StepContext() |