(self)
| 1431 | return batch |
| 1432 | |
| 1433 | def max_batch_size(self) -> int: |
| 1434 | batch_frac = 1 / len(self.workers) |
| 1435 | if sys.platform == "linux": |
| 1436 | # Linux is good with socket roundtrip latency, so we can use |
| 1437 | # more fine-grained batches. |
| 1438 | batch_frac /= 2 |
| 1439 | return int(self.size_in_queue * batch_frac) |
| 1440 | |
| 1441 | def submit_to_workers(self, graph: Graph, sccs: list[SCC] | None = None) -> None: |
| 1442 | if sccs is not None: |
no test coverage detected