Changeset View
Changeset View
Standalone View
Standalone View
swh/web/common/origin_save.py
| Show First 20 Lines • Show All 158 Lines • ▼ Show 20 Lines | if time_delta.days <= 30: | ||||
| origin = {"url": save_request.origin_url} | origin = {"url": save_request.origin_url} | ||||
| origin_info = service.lookup_origin(origin) | origin_info = service.lookup_origin(origin) | ||||
| origin_visits = get_origin_visits(origin_info) | origin_visits = get_origin_visits(origin_info) | ||||
| visit_dates = [parse_iso8601_date_to_utc(v["date"]) for v in origin_visits] | visit_dates = [parse_iso8601_date_to_utc(v["date"]) for v in origin_visits] | ||||
| i = bisect_right(visit_dates, save_request.request_date) | i = bisect_right(visit_dates, save_request.request_date) | ||||
| if i != len(visit_dates): | if i != len(visit_dates): | ||||
| visit_date = visit_dates[i] | visit_date = visit_dates[i] | ||||
| visit_status = origin_visits[i]["status"] | visit_status = origin_visits[i]["status"] | ||||
| if origin_visits[i]["status"] == "ongoing": | if origin_visits[i]["status"] not in ("full", "partial"): | ||||
ardumont: Can't you do this directly when calling the storage? | |||||
Done Inline ActionsRight it should be possible to filter visit statuses through the storage API. I will see what I can do before landing this. anlambert: Right it should be possible to filter visit statuses through the storage API. I will see what I… | |||||
Done Inline ActionsI am landing this in order to fix the bad reported save status in production and I will try to improve the code using storage API later. anlambert: I am landing this in order to fix the bad reported save status in production and I will try to… | |||||
Not Done Inline Actionssure ;) ardumont: sure ;) | |||||
| visit_date = None | visit_date = None | ||||
| except Exception as exc: | except Exception as exc: | ||||
| sentry_sdk.capture_exception(exc) | sentry_sdk.capture_exception(exc) | ||||
| return visit_date, visit_status | return visit_date, visit_status | ||||
| def _check_visit_update_status(save_request, save_task_status): | def _check_visit_update_status(save_request, save_task_status): | ||||
| visit_date, visit_status = _get_visit_info_for_save_request(save_request) | visit_date, visit_status = _get_visit_info_for_save_request(save_request) | ||||
| ▲ Show 20 Lines • Show All 445 Lines • Show Last 20 Lines | |||||
Can't you do this directly when calling the storage?