(self, tids, specs, results, miscs)
| 452 | return rval |
| 453 | |
| 454 | def new_trial_docs(self, tids, specs, results, miscs): |
| 455 | assert len(tids) == len(specs) == len(results) == len(miscs) |
| 456 | trials_docs = [] |
| 457 | for tid, spec, result, misc in zip(tids, specs, results, miscs): |
| 458 | doc = { |
| 459 | "state": JOB_STATE_NEW, |
| 460 | "tid": tid, |
| 461 | "spec": spec, |
| 462 | "result": result, |
| 463 | "misc": misc, |
| 464 | "exp_key": self._exp_key, |
| 465 | "owner": None, |
| 466 | "version": 0, |
| 467 | "book_time": None, |
| 468 | "refresh_time": None, |
| 469 | } |
| 470 | trials_docs.append(doc) |
| 471 | return trials_docs |
| 472 | |
| 473 | def source_trial_docs(self, tids, specs, results, miscs, sources): |
| 474 | assert len(tids) == len(specs) == len(results) == len(miscs) == len(sources) |
no outgoing calls