refactor: force analysis by default for CLI and API call

udata_hydra/cli.py

@@ -137,7 +137,7 @@ async def crawl_url(url: str, method: str = "get"):
 
 
 @cli
-async def check_resource(resource_id: str, method: str = "get", force_analysis: bool = False):
+async def check_resource(resource_id: str, method: str = "get", force_analysis: bool = True):
     """Trigger a complete check for a given resource_id"""
     resource: asyncpg.Record | None = await Resource.get(resource_id)
     if not resource:

udata_hydra/crawl/check_resources.py

@@ -58,10 +58,10 @@ async def check_resource(
     url: str,
     resource_id: str,
     session,
-    force_analysis: bool = False,
     sleep: float = 0,
     method: str = "head",
     worker_priority: str = "default",
+    force_analysis: bool = False,
 ) -> str:
     log.debug(f"check {url}, sleep {sleep}, method {method}")
 
@@ -128,7 +128,7 @@ async def check_resource(
             await Resource.update(resource_id, data={"status": "TO_ANALYSE_RESOURCE"})
 
             # Enqueue the resource for analysis
-            queue.enqueue(analyse_resource, check["id"], is_first_check, _priority=worker_priority)
+            queue.enqueue(analyse_resource, check["id"], is_first_check, force_analysis, _priority=worker_priority)
 
             return RESOURCE_RESPONSE_STATUSES["OK"]
 

udata_hydra/routes/checks.py

@@ -64,7 +64,7 @@ async def create_check(request: web.Request) -> web.Response:
     try:
         payload: dict = await request.json()
         resource_id: str = payload["resource_id"]
-        force_analysis: bool = payload.get("force_analysis", False)
+        force_analysis: bool = payload.get("force_analysis", True)
     except Exception as err:
         raise web.HTTPBadRequest(text=json.dumps({"error": str(err)}))