Submit a stale SCC for processing in current process or parallel workers.
(self, graph: Graph, sccs: list[SCC])
| 1402 | ) from exc |
| 1403 | |
| 1404 | def submit(self, graph: Graph, sccs: list[SCC]) -> None: |
| 1405 | """Submit a stale SCC for processing in current process or parallel workers.""" |
| 1406 | if self.workers: |
| 1407 | self.submit_to_workers(graph, sccs) |
| 1408 | else: |
| 1409 | self.scc_queue.extend([(0, 0, scc) for scc in sccs]) |
| 1410 | |
| 1411 | def get_scc_batch(self, max_size_in_batch: int) -> list[SCC]: |
| 1412 | """Get a batch of SCCs from queue to submit to a worker. |
no test coverage detected