From 128e49c337d7abef54c4ceb29c65cd0e8e2d65b8 Mon Sep 17 00:00:00 2001 From: Florian Pinault Date: Mon, 1 Jul 2024 14:22:51 +0000 Subject: [PATCH] remove trace_info --- src/anemoi/registry/queue_manager.py | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/src/anemoi/registry/queue_manager.py b/src/anemoi/registry/queue_manager.py index 7199ef8..0894622 100644 --- a/src/anemoi/registry/queue_manager.py +++ b/src/anemoi/registry/queue_manager.py @@ -7,11 +7,12 @@ import datetime import logging + from anemoi.utils.humanize import when from anemoi.utils.text import table -from anemoi.utils.provenance import trace_info -import anemoi.registry.rest as rest +# from anemoi.utils.provenance import trace_info +import anemoi.registry.rest as rest LOG = logging.getLogger(__name__) @@ -27,6 +28,7 @@ def add(record): LOG.info(f"Added {response} to queue.") return response["uuid"] + def remove(uuid): return REST.delete(COLLECTION, uuid) @@ -42,7 +44,7 @@ def set_status(uuid, status): def own(uuid): - trace = trace_info(details=True) + trace = {} # trace_info(details=True) patch = [ {"op": "test", "path": "/status", "value": "queued"}, {"op": "replace", "path": "/status", "value": "running"}, @@ -50,6 +52,7 @@ def own(uuid): ] return REST.patch(f"{COLLECTION}/{uuid}", patch) + def disown(uuid): patch = [ {"op": "test", "path": "/status", "value": "running"}, @@ -122,7 +125,7 @@ def main(): own(latest) return - + if args.disown: disown(args.disown)