fix: remove name comparison

Signed-off-by: 35C4n0r <[email protected]>
35C4n0r · Sep 27, 2024 · 52cb6cd · 52cb6cd
1 parent d5dbd79
commit 52cb6cd
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 3 deletions.
diff --git a/keep/api/core/db.py b/keep/api/core/db.py
@@ -551,7 +551,7 @@ def get_workflow(tenant_id: str, workflow_id: str) -> Workflow:
             workflow = session.exec(
                 select(Workflow)
                 .where(Workflow.tenant_id == tenant_id)
-                .where(Workflow.name == workflow_id)
+                .where(Workflow.id == workflow_id)
                 .where(Workflow.is_deleted == False)
             ).first()
     if not workflow:

diff --git a/keep/api/routes/workflows.py b/keep/api/routes/workflows.py
@@ -304,7 +304,10 @@ async def __get_workflow_raw_data(
         is_valid = True
     except Exception as e:
         is_valid = False
-        logger.error(f"Error while validating workflow yaml {workflow_data['id']}", extra={"exception": e})
+        logger.error(
+            f"Error while validating workflow yaml {workflow_data['id']}",
+            extra={"exception": e},
+        )
 
     return workflow_data, is_valid
 

diff --git a/keep/workflowmanager/workflowstore.py b/keep/workflowmanager/workflowstore.py
@@ -325,7 +325,10 @@ def provision_workflows_from_directory(
                             tenant_id=tenant_id, parsed_workflow_yaml=workflow_yaml
                         )
                     except Exception as e:
-                        logger.error(f"Error while validating workflow yaml {workflow_id}", extra={"exception": e})
+                        logger.error(
+                            f"Error while validating workflow yaml {workflow_id}",
+                            extra={"exception": e},
+                        )
                         is_valid = False
                     add_or_update_workflow(
                         id=workflow_id,