Add missing handler

timgates42 · Mar 24, 2020 · d710521 · d710521
1 parent 019c6d9
commit d710521
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 5 deletions.
diff --git a/app/meticulous/_addrepo.py b/app/meticulous/_addrepo.py
@@ -32,6 +32,7 @@ def addrepo_handlers():
     return {
         "repository_load": repository_load,
         "repository_checkout": repository_checkout,
+        "repository_summary": repository_summary,
     }
 
 

diff --git a/app/meticulous/_multiworker.py b/app/meticulous/_multiworker.py
@@ -20,7 +20,7 @@ def update_workload(workload):
     result = list(workload)
     load_count = count_names(workload, {"repository_load"})
     active_count = len(get_json_value("repository_map", {}))
-    for _ in range(3 - active_count - load_count):
+    for _ in range(2 - active_count - load_count):
         result.append({"interactive": True, "name": "repository_load", "priority": 40})
     if count_names(workload, {"wait_threadpool"}) < 1:
         result.append({"interactive": True, "name": "wait_threadpool", "priority": 999})

diff --git a/app/meticulous/_multiworker_test.py b/app/meticulous/_multiworker_test.py
@@ -19,7 +19,7 @@ def test_empty_load(get_mock):
     result = update_workload(initial)
     # Verify
     check = [1 for elem in result if elem["name"] == "repository_load"]
-    assert len(check) == 3  # noqa=S101 # nosec
+    assert len(check) == 2  # noqa=S101 # nosec
 
 
 @mock.patch("meticulous._multiworker.get_json_value")

diff --git a/app/meticulous/_process.py b/app/meticulous/_process.py
@@ -274,7 +274,7 @@ def task_collect_nonwords(obj, eng):  # pylint: disable=unused-argument
     key = "repository_map"
     repository_list = get_json_value(key, {})
     count = len(repository_list)
-    if count != 1:
+    if count < 1:
         print(f"Unexpected number of repostories - {count}")
         return
     reponame = next(iter(repository_list.keys()))
@@ -287,7 +287,7 @@ def task_submit(obj, eng):  # pylint: disable=unused-argument
     """
     repository_saves = get_json_value("repository_saves", {})
     count = len(repository_saves)
-    if count != 1:
+    if count < 1:
         print(f"Unexpected number of repostories - {count}")
         return
     reponame, reposave = next(iter(repository_saves.items()))
@@ -301,7 +301,7 @@ def task_cleanup(obj, eng):  # pylint: disable=unused-argument
     key = "repository_map"
     repository_map = get_json_value(key, {})
     count = len(repository_map)
-    if count != 1:
+    if count < 1:
         print(f"Unexpected number of repostories - {count}")
         return
     reponame, reposave = next(iter(repository_map.items()))