Returns the list of subtasks names that should be run for given scope and entity types.
(self, scope: ToolScope, config: ScopeConfig)
| 197 | return [] |
| 198 | |
| 199 | def select_subtasks(self, scope: ToolScope, config: ScopeConfig) -> list[str]: |
| 200 | """ |
| 201 | Returns the list of subtasks names that should be run for given scope and entity types. |
| 202 | """ |
| 203 | subtasks = [] |
| 204 | for stream in self._streams.values(): |
| 205 | if set(stream.domain_types).intersection(config.domain_types) and stream.should_run_on(scope): |
| 206 | for subtask in stream.subtasks: |
| 207 | subtasks.append(subtask.name) |
| 208 | return subtasks |
| 209 | |
| 210 | def get_stream(self, stream_name: str) -> Stream: |
| 211 | stream = self._streams.get(stream_name) |
no test coverage detected