feat: Merge branch 'feature/test' of https://github.com/palad-in/keep …

…into feature/test
keephq · Dec 27, 2024 · 9f44716 · 9f44716
2 parents d36253d + e66d619
commit 9f44716
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 4 deletions.
diff --git a/keep/api/core/demo_mode.py b/keep/api/core/demo_mode.py
@@ -568,7 +568,6 @@ async def simulate_alerts_async(
         logger.info(
             "Sleeping for {} seconds before next iteration".format(sleep_interval)
         )
-    # await asyncio.sleep(sleep_interval)
 
 
 def launch_demo_mode_thread(

diff --git a/keep/api/routes/alerts.py b/keep/api/routes/alerts.py
@@ -295,7 +295,7 @@ def discard_future(
                     },
                 )
         except concurrent.futures.CancelledError:
-            logger.info(
+            logger.error(
                 "Task was cancelled",
                 extra={
                     "trace_id": trace_id,
@@ -347,7 +347,6 @@ def create_process_event_task(
     future.add_done_callback(
         lambda task: discard_future(trace_id, task, running_tasks, started_time)
     )
-    # bg_tasks.add_task(task)
 
     logger.info("Task added", extra={"trace_id": trace_id})
     return str(id(future))

diff --git a/keep/workflowmanager/workflowscheduler.py b/keep/workflowmanager/workflowscheduler.py
@@ -69,7 +69,7 @@ def wrapper(*args, **kwargs):
 
 class WorkflowScheduler:
     MAX_SIZE_SIGNED_INT = 2147483647
-    MAX_WORKERS = 20
+    MAX_WORKERS = config("KEEP_MAX_WORKFLOW_WORKERS", default="20", cast=int)
 
     def __init__(self, workflow_manager):
         self.logger = logging.getLogger(__name__)