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