srenblad
/
artiq
forked from M-Labs/artiq
1
0
Fork 0
Code Pull Requests Activity

test/scheduler: add repo_msg

This commit is contained in:
Sebastien Bourdeauducq 2015-08-10 20:07:24 +08:00
parent af230f6cf3
commit 52de6311a4
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
artiq/test/scheduler.py
View File

@ -37,7 +37,8 @@ def _get_basic_steps(rid, expid, priority=0, flush=False):
return [ return [
{"action": "setitem", "key": rid, "value": {"action": "setitem", "key": rid, "value":
{"pipeline": "main", "status": "pending", "priority": priority, {"pipeline": "main", "status": "pending", "priority": priority,
"expid": expid, "due_date": None, "flush": flush}, "expid": expid, "due_date": None, "flush": flush,
"repo_msg": None},
"path": []}, "path": []},
{"action": "setitem", "key": "status", "value": "preparing", {"action": "setitem", "key": "status", "value": "preparing",
"path": [rid]}, "path": [rid]},
@ -89,7 +90,8 @@ class SchedulerCase(unittest.TestCase):
expect.insert(0, expect.insert(0,
{"action": "setitem", "key": 0, "value": {"action": "setitem", "key": 0, "value":
{"pipeline": "main", "status": "pending", "priority": 99, {"pipeline": "main", "status": "pending", "priority": 99,
"expid": expid, "due_date": late, "flush": False}, "expid": expid, "due_date": late, "flush": False,
"repo_msg": None},
"path": []}) "path": []})
scheduler.submit("main", expid, 99, late, False) scheduler.submit("main", expid, 99, late, False)