rename queues to tasks

src/anemoi/registry/commands/entry.py

@@ -90,7 +90,7 @@ def run(self, args):
             raise ValueError("Invalid API path {path}")
 
         _, collection, *_ = path.split("/")
-        if collection not in ("datasets", "experiments", "weights", "queues"):
+        if collection not in ("datasets", "experiments", "weights", "tasks"):
             LOG.warning(f"Unknown collection {collection}")
 
         if args.edit:

src/anemoi/registry/commands/list.py

@@ -64,7 +64,7 @@ def _run_default(self, args):
         print(json_pretty_dump(payload))
 
     def run_tasks(self, args):
-        collection = "queues"
+        collection = "tasks"
         request = list_to_dict(args.filter)
         data = RestItemList(collection).get(params=request)
         self.print_tasks(data, long=args.long, sort=args.sort)

src/anemoi/registry/commands/tasks.py

@@ -64,7 +64,7 @@ class Tasks(BaseCommand):
     timestamp = True
     entry_class = TaskCatalogueEntry
 
-    collection = "queues"
+    collection = "tasks"
 
     def add_arguments(self, command_parser):
         command_parser.add_argument("TASK", help="The uuid of the task", nargs="?")

src/anemoi/registry/tasks.py

@@ -113,7 +113,7 @@ def actor_factory(**record):
 
 
 class TaskCatalogueEntry(CatalogueEntry):
-    collection = "queues"
+    collection = "tasks"
     main_key = "uuid"
 
     def to_actor(self):