| 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) |
| 475 | rval = [] |
| 476 | for tid, spec, result, misc, source in zip( |
| 477 | tids, specs, results, miscs, sources |
| 478 | ): |
| 479 | doc = dict( |
| 480 | version=0, |
| 481 | tid=tid, |
| 482 | spec=spec, |
| 483 | result=result, |
| 484 | misc=misc, |
| 485 | state=source["state"], |
| 486 | exp_key=source["exp_key"], |
| 487 | owner=source["owner"], |
| 488 | book_time=source["book_time"], |
| 489 | refresh_time=source["refresh_time"], |
| 490 | ) |
| 491 | # -- ensure that misc has the following fields, |
| 492 | # some of which may already by set correctly. |
| 493 | assign = ("tid", tid), ("cmd", None), ("from_tid", source["tid"]) |
| 494 | for k, v in assign: |
| 495 | assert doc["misc"].setdefault(k, v) == v |
| 496 | rval.append(doc) |
| 497 | return rval |
| 498 | |
| 499 | def delete_all(self): |
| 500 | self._dynamic_trials = [] |