Create and return a SchedulerConfig object based on the current settings.
(self)
| 1367 | return SpeculativeConfig(speculative_args) |
| 1368 | |
| 1369 | def create_scheduler_config(self) -> SchedulerConfig: |
| 1370 | """ |
| 1371 | Create and return a SchedulerConfig object based on the current settings. |
| 1372 | """ |
| 1373 | prefix = "scheduler_" |
| 1374 | prefix_len = len(prefix) |
| 1375 | |
| 1376 | all = asdict(self) |
| 1377 | all.pop("port") # port and scheduler_port are not the same |
| 1378 | params = dict() |
| 1379 | for k, v in all.items(): |
| 1380 | if k[:prefix_len] == prefix: |
| 1381 | params[k[prefix_len:]] = v |
| 1382 | else: |
| 1383 | params[k] = v |
| 1384 | return SchedulerConfig(params) |
| 1385 | |
| 1386 | def create_graph_optimization_config(self) -> GraphOptimizationConfig: |
| 1387 | """ |
no test coverage detected