remove print statements from celeryadapter.py

LLNL · Nov 30, 2023 · ce945d0 · ce945d0
1 parent 4b3bd48
commit ce945d0
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/merlin/study/celeryadapter.py b/merlin/study/celeryadapter.py
@@ -352,17 +352,14 @@ def check_celery_workers_processing(queues_in_spec: List[str], app: Celery) -> b
     """
     # Query celery for active tasks
     active_tasks = app.control.inspect().active()
-    print(f"active_tasks: {active_tasks}")
 
     # Search for the queues we provided if necessary
     if active_tasks is not None:
         for tasks in active_tasks.values():
             for task in tasks:
                 if task["delivery_info"]["routing_key"] in queues_in_spec:
-                    print("Workers are still active")
                     return True
 
-    print("Workers are no longer active")
     return False