Page MenuHomeSoftware Heritage
Files F7066582

D5028.id.diff
No OneTemporary
Actions

D5028.id.diff
View Options

diff --git a/swh/scheduler/journal_client.py b/swh/scheduler/journal_client.py
--- a/swh/scheduler/journal_client.py
+++ b/swh/scheduler/journal_client.py
@@ -80,6 +80,10 @@
visit_stats_d["last_notfound"] = max_date(
msg_dict["date"], visit_stats_d.get("last_notfound")
)
+ elif msg_dict["status"] == "failed":
+ visit_stats_d["last_failed"] = max_date(
+ msg_dict["date"], visit_stats_d.get("last_failed")
+ )
elif msg_dict["snapshot"] is None:
visit_stats_d["last_failed"] = max_date(
msg_dict["date"], visit_stats_d.get("last_failed")
diff --git a/swh/scheduler/tests/test_journal_client.py b/swh/scheduler/tests/test_journal_client.py
--- a/swh/scheduler/tests/test_journal_client.py
+++ b/swh/scheduler/tests/test_journal_client.py
@@ -214,6 +214,44 @@
]
+def test_journal_client_origin_visit_status_from_journal_last_failed2(swh_scheduler):
+ visit_statuses = [
+ {
+ "origin": "bar",
+ "visit": 2,
+ "status": "failed",
+ "date": DATE1,
+ "type": "git",
+ "snapshot": hash_to_bytes("d81cc0710eb6cf9efd5b920a8453e1e07157b6cd"),
+ },
+ {
+ "origin": "bar",
+ "visit": 3,
+ "status": "failed",
+ "date": DATE2,
+ "type": "git",
+ "snapshot": None,
+ },
+ ]
+
+ process_journal_objects(
+ {"origin_visit_status": visit_statuses}, scheduler=swh_scheduler
+ )
+
+ actual_origin_visit_stats = swh_scheduler.origin_visit_stats_get([("bar", "git")])
+ assert actual_origin_visit_stats == [
+ OriginVisitStats(
+ url="bar",
+ visit_type="git",
+ last_eventful=None,
+ last_uneventful=None,
+ last_failed=DATE2,
+ last_notfound=None,
+ last_snapshot=None,
+ )
+ ]
+
+
def test_journal_client_origin_visit_status_from_journal_last_eventful(swh_scheduler):
visit_statuses = [
{

File Metadata

Mime Type
text/plain
Expires
Nov 5 2024, 3:25 PM (12 w, 4 d ago)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
3220454

Event Timeline

About · Developer information · Legal