(self, args)
| 104 | |
| 105 | class JobManager: |
| 106 | def __init__(self, args): |
| 107 | self.past_jobs = [] |
| 108 | self.work_queue = multiprocessing.Queue() |
| 109 | self.result_queue = multiprocessing.Queue() |
| 110 | self.next_job_id = 0 |
| 111 | self.args = args |
| 112 | self.workers = JobWorkers(args) |
| 113 | self.workers.launch(self.work_queue, self.result_queue) |
| 114 | |
| 115 | def _add_job(self, task_op, code = None, test = None): |
| 116 | job_id = self.next_job_id |
nothing calls this directly
no test coverage detected