swh_scheduler = <swh.scheduler.backend.SchedulerBackend object at 0x7f4f10062ba8> def test_journal_client_origin_visit_status_several_upsert(swh_scheduler): """An old message updates old information """ visit_status1 = { "origin": "foo", "visit": 1, "status": "full", "date": DATE1, "type": "git", "snapshot": hash_to_bytes("aaaaaabbbeb6cf9efd5b920a8453e1e07157b6cd"), } visit_status2 = { "origin": "foo", "visit": 1, "status": "full", "date": DATE2, "type": "git", "snapshot": hash_to_bytes("aaaaaabbbeb6cf9efd5b920a8453e1e07157b6cd"), } process_journal_objects( {"origin_visit_status": [visit_status2]}, scheduler=swh_scheduler ) process_journal_objects( {"origin_visit_status": [visit_status1]}, scheduler=swh_scheduler ) > assert swh_scheduler.origin_visit_stats_get([("foo", "git")]) == [ OriginVisitStats( url="foo", visit_type="git", last_eventful=DATE1, last_uneventful=DATE2, last_failed=None, last_notfound=None, last_snapshot=hash_to_bytes("aaaaaabbbeb6cf9efd5b920a8453e1e07157b6cd"), next_visit_queue_position=None, next_position_offset=5, ) ] E AssertionError: assert [OriginVisitS...ion_offset=5)] == [OriginVisitS...ion_offset=5)] E At index 0 diff: OriginVisitStats(url='foo', visit_type='git', last_eventful=datetime.datetime(2021, 6, 28, 8, 7, 44, 578859, tzinfo=datetime.timezone.utc), last_uneventful=datetime.datetime(2021, 6, 29, 8, 7, 44, 578859, tzinfo=datetime.timezone.utc), last_failed=None, last_notfound=None, last_scheduled=None, last_snapshot=b'\xaa\xaa\xaa\xbb\xbe\xb6\xcf\x9e\xfd[\x92\n\x84S\xe1\xe0qW\xb6\xcd', next_visit_queue_position=datetime.datetime(2021, 7, 6, 11, 30, 21, 704810, tzinfo=datetime.timezone.utc), next_position_offset=5) != OriginVisitStats(url='foo', visit_type='git',... E E ...Full output truncated (6 lines hidden), use '-vv' to show .tox/py3/lib/python3.7/site-packages/swh/scheduler/tests/test_journal_client.py:699: AssertionError