Changeset View
Changeset View
Standalone View
Standalone View
swh/scheduler/tests/test_journal_client.py
| Show First 20 Lines • Show All 483 Lines • ▼ Show 20 Lines | |||||
| def test_journal_client_origin_visit_status_permutation1(visit_statuses, swh_scheduler): | def test_journal_client_origin_visit_status_permutation1(visit_statuses, swh_scheduler): | ||||
| """Ensure out of order topic subscription ends up in the same final state | """Ensure out of order topic subscription ends up in the same final state | ||||
| """ | """ | ||||
| process_journal_objects( | process_journal_objects( | ||||
| {"origin_visit_status": visit_statuses}, scheduler=swh_scheduler | {"origin_visit_status": visit_statuses}, scheduler=swh_scheduler | ||||
| ) | ) | ||||
| expected_visit_stats = OriginVisitStats( | (actual_visit_stats,) = swh_scheduler.origin_visit_stats_get([("cavabarder", "hg")]) | ||||
| url="cavabarder", | |||||
| visit_type="hg", | |||||
| last_eventful=DATE1 + 2 * ONE_DAY, | |||||
| last_uneventful=DATE1 + 3 * ONE_DAY, | |||||
| last_failed=None, | |||||
| last_notfound=None, | |||||
| last_snapshot=hash_to_bytes("aaaaaabbbeb6cf9efd5b920a8453e1e07157b6cd"), | |||||
| ) | |||||
| assert swh_scheduler.origin_visit_stats_get([("cavabarder", "hg")]) == [ | assert actual_visit_stats.url == "cavabarder" | ||||
| expected_visit_stats | assert actual_visit_stats.visit_type == "hg" | ||||
| ] | assert actual_visit_stats.last_eventful == DATE1 + 2 * ONE_DAY | ||||
| assert actual_visit_stats.last_uneventful == DATE1 + 3 * ONE_DAY | |||||
| assert actual_visit_stats.last_failed is None | |||||
| assert actual_visit_stats.last_notfound is None | |||||
| assert actual_visit_stats.last_snapshot == hash_to_bytes( | |||||
| "aaaaaabbbeb6cf9efd5b920a8453e1e07157b6cd" | |||||
| ) | |||||
| VISIT_STATUSES_2 = [ | VISIT_STATUSES_2 = [ | ||||
| {**ovs, "date": DATE1 + n * ONE_DAY} | {**ovs, "date": DATE1 + n * ONE_DAY} | ||||
| for n, ovs in enumerate( | for n, ovs in enumerate( | ||||
| [ | [ | ||||
| { | { | ||||
| "origin": "cavabarder", | "origin": "cavabarder", | ||||
| ▲ Show 20 Lines • Show All 240 Lines • Show Last 20 Lines | |||||