IDSIA /
sacred
| @@ 215-226 (lines=12) @@ | ||
| 212 | db_run = tinydb_obs.runs.get(eid=1) |
|
| 213 | assert db_run['stop_time'] == T2 |
|
| 214 | assert db_run['status'] == 'INTERRUPTED' |
|
| 215 | ||
| 216 | ||
| 217 | def test_tinydb_observer_failed_event_updates_run(tinydb_obs, sample_run): |
|
| 218 | tinydb_obs.started_event(**sample_run) |
|
| 219 | ||
| 220 | fail_trace = "lots of errors and\nso\non..." |
|
| 221 | tinydb_obs.failed_event(fail_time=T2, |
|
| 222 | fail_trace=fail_trace) |
|
| 223 | ||
| 224 | assert len(tinydb_obs.runs) == 1 |
|
| 225 | db_run = tinydb_obs.runs.get(eid=1) |
|
| 226 | assert db_run['stop_time'] == T2 |
|
| 227 | assert db_run['status'] == 'FAILED' |
|
| 228 | assert db_run['fail_trace'] == fail_trace |
|
| 229 | ||
| @@ 126-137 (lines=12) @@ | ||
| 123 | assert mongo_obs.runs.count() == 1 |
|
| 124 | db_run = mongo_obs.runs.find_one() |
|
| 125 | assert db_run['stop_time'] == T2 |
|
| 126 | assert db_run['status'] == 'INTERRUPTED' |
|
| 127 | ||
| 128 | ||
| 129 | def test_mongo_observer_failed_event_updates_run(mongo_obs, sample_run): |
|
| 130 | mongo_obs.started_event(**sample_run) |
|
| 131 | ||
| 132 | fail_trace = "lots of errors and\nso\non..." |
|
| 133 | mongo_obs.failed_event(fail_time=T2, |
|
| 134 | fail_trace=fail_trace) |
|
| 135 | ||
| 136 | assert mongo_obs.runs.count() == 1 |
|
| 137 | db_run = mongo_obs.runs.find_one() |
|
| 138 | assert db_run['stop_time'] == T2 |
|
| 139 | assert db_run['status'] == 'FAILED' |
|
| 140 | assert db_run['fail_trace'] == fail_trace |
|
