Add `command` to the processing pipeline. Will be called after processing the input.
(self, command: ty.Callable, command_args: dict[str, ty.Any])
| 110 | self.commands: list[tuple[ty.Callable, dict[str, ty.Any]]] = [] |
| 111 | |
| 112 | def add_command(self, command: ty.Callable, command_args: dict[str, ty.Any]): |
| 113 | """Add `command` to the processing pipeline. Will be called after processing the input.""" |
| 114 | if "output" in command_args and command_args["output"] is None: |
| 115 | command_args["output"] = self.output |
| 116 | logger.debug("Adding command: %s(%s)", command.__name__, command_args) |
| 117 | self.commands.append((command, command_args)) |
| 118 | |
| 119 | def add_detector(self, detector: type[SceneDetector], detector_args: dict[str, ty.Any]): |
| 120 | """Instantiate and add `detector` to the processing pipeline.""" |
no outgoing calls
no test coverage detected