feat: Workflow refactoring, only async

.github/workflows/test-pr.yml

@@ -95,7 +95,7 @@ jobs:
           LOG_LEVEL: DEBUG
           SQLALCHEMY_WARN_20: 1
         run: |
-          poetry run coverage run --branch -m pytest --timeout 20 -n auto --non-integration --ignore=tests/e2e_tests/
+          poetry run coverage run --branch -m pytest -n auto --non-integration --ignore=tests/e2e_tests/
 
       - name: Run integration tests and report coverage
         run: |

docs/mint.json

@@ -121,6 +121,7 @@
             "providers/documentation/checkmk-provider",
             "providers/documentation/cilium-provider",
             "providers/documentation/clickhouse-provider",
+            "providers/documentation/clickhouse-http-provider",
             "providers/documentation/cloudwatch-provider",
             "providers/documentation/console-provider",
             "providers/documentation/coralogix-provider",

docs/providers/documentation/clickhouse-http-provider.mdx

@@ -0,0 +1,7 @@
+---
+title: 'ClickHouse HTTP'
+sidebarTitle: 'ClickHouse HTTP Provider'
+description: 'ClickHouse HTTP provider allows you to interact with ClickHouse database.'
+---
+
+This provider is an async (more performant) analog of [clickhouse-provider](providers/documentation/clickhouse-provider.mdx). It's using HTTP protocol to interact to the Clickhouse.

docs/providers/overview.mdx

@@ -156,6 +156,12 @@ By leveraging Keep Providers, users are able to deeply integrate Keep with the t
   }
 ></Card>
 
+<Card
+  title="ClickHouse HTTP"
+  href="/providers/documentation/clickhouse-http-provider"
+  icon={ <img src="https://img.logo.dev/clickhouse.com?token=pk_dfXfZBoKQMGDTIgqu7LvYg" /> }
+></Card>
+
 <Card
   title="ClickHouse"
   href="/providers/documentation/clickhouse-provider"

keep/api/bl/incidents_bl.py

@@ -1,3 +1,4 @@
+import asyncio
 import logging
 import os
 import pathlib
@@ -153,7 +154,7 @@ def update_client_on_incident_change(self, incident_id: Optional[UUID] = None):
     def send_workflow_event(self, incident_dto: IncidentDto, action: str) -> None:
         try:
             workflow_manager = WorkflowManager.get_instance()
-            workflow_manager.insert_incident(self.tenant_id, incident_dto, action)
+            asyncio.run(workflow_manager.insert_incident(self.tenant_id, incident_dto, action))
         except Exception:
             self.logger.exception(
                 "Failed to run workflows based on incident",
@@ -231,6 +232,7 @@ def delete_incident(self, incident_id: UUID) -> None:
         self.update_client_on_incident_change()
         self.send_workflow_event(incident_dto, "deleted")
 
+
     def update_incident(
         self,
         incident_id: UUID,