fix: tmp

Author: aldbr

diracx-logic/src/diracx/logic/jobs/query.py

@@ -103,4 +103,7 @@ async def summary(
                 "value": preferred_username,
             }
         )
+    print(f"Summary search: {body.search}")
+    print(f"Summary grouping: {body.grouping}")
+    print(f"Preferred username: {preferred_username}")
     return await job_db.summary(body.grouping, body.search)

diracx-logic/src/diracx/logic/jobs/status.py

@@ -524,6 +524,7 @@ async def set_job_parameters_or_attributes(
     # Those dicts create a mapping of job_id -> {attribute_name: value}
     attr_updates: dict[int, dict[str, Any]] = {}
     param_updates: dict[int, dict[str, Any]] = {}
+    print("METADATA", updates)
 
     for job_id, metadata in updates.items():
         attr_updates[job_id] = {}
@@ -554,6 +555,9 @@ async def set_job_parameters_or_attributes(
     # Bulk set job parameters if required
     await _insert_parameters(param_updates, job_parameters_db, job_db)
 
+    print("PARAMETERS", param_updates)
+    print("ATTRIBUTES", attr_updates)
+
 
 async def add_heartbeat(
     data: dict[int, HeartbeatData],

diracx-routers/src/diracx/routers/jobs/status.py

@@ -4,7 +4,7 @@
 from http import HTTPStatus
 from typing import Annotated, Any
 
-from fastapi import Body, HTTPException, Query
+from fastapi import Body, HTTPException, Query, Request
 
 from diracx.core.models import (
     HeartbeatData,
@@ -264,6 +264,7 @@ async def reschedule_jobs(
 
 @router.patch("/metadata", status_code=HTTPStatus.NO_CONTENT)
 async def patch_metadata(
+    request: Request,
     updates: Annotated[dict[int, JobMetaData], Body(openapi_examples=EXAMPLE_METADATA)],
     job_db: JobDB,
     job_parameters_db: JobParametersDB,
@@ -272,6 +273,8 @@ async def patch_metadata(
     """Update job metadata such as UserPriority, HeartBeatTime, JobType, etc.
     The argument  are all the attributes/parameters of a job (except the ID).
     """
+    # display raw request body for debugging
+    print(f"RAW REQUEST BODY {await request.body()}")
     await check_permissions(action=ActionType.MANAGE, job_db=job_db, job_ids=updates)
     try:
         await set_job_parameters_or_attributes_bl(updates, job_db, job_parameters_db)