Spaces:
Running
Running
Commit ·
f8c4791
1
Parent(s): 79879d4
ok
Browse files
app/api/v1/keys_extract.py
CHANGED
|
@@ -151,15 +151,15 @@ async def extract_keys_batch(body: KeysExtractBatchRequest):
|
|
| 151 |
``{"matches": [{"path": "users.[0].role", "value": "admin"}, ...]}``.
|
| 152 |
"""
|
| 153 |
start = time.perf_counter()
|
| 154 |
-
logger.info("keys_extract_batch | start
|
| 155 |
tasks = [_extract_single(req) for req in body.requests]
|
| 156 |
results = await asyncio.gather(*tasks)
|
| 157 |
elapsed = round((time.perf_counter() - start) * 1000, 3)
|
| 158 |
all_ok = all(r.success for r in results)
|
| 159 |
logger.info(
|
| 160 |
-
"keys_extract_batch | done",
|
| 161 |
-
|
| 162 |
-
|
| 163 |
-
|
| 164 |
)
|
| 165 |
return KeysExtractBatchResponse(success=all_ok, time_ms=elapsed, results=results)
|
|
|
|
| 151 |
``{"matches": [{"path": "users.[0].role", "value": "admin"}, ...]}``.
|
| 152 |
"""
|
| 153 |
start = time.perf_counter()
|
| 154 |
+
logger.info("keys_extract_batch | start count=%d", len(body.requests))
|
| 155 |
tasks = [_extract_single(req) for req in body.requests]
|
| 156 |
results = await asyncio.gather(*tasks)
|
| 157 |
elapsed = round((time.perf_counter() - start) * 1000, 3)
|
| 158 |
all_ok = all(r.success for r in results)
|
| 159 |
logger.info(
|
| 160 |
+
"keys_extract_batch | done total=%d succeeded=%d time_ms=%s",
|
| 161 |
+
len(results),
|
| 162 |
+
sum(1 for r in results if r.success),
|
| 163 |
+
elapsed,
|
| 164 |
)
|
| 165 |
return KeysExtractBatchResponse(success=all_ok, time_ms=elapsed, results=results)
|