From c6fdf4409b1bc5ee13427ba2bb594c900eef6c45 Mon Sep 17 00:00:00 2001
From: shamoon <4887959+shamoon@users.noreply.github.com>
Date: Sun, 24 Nov 2024 12:22:48 -0800
Subject: [PATCH] Fix: include distinct on workflow objects filter

---
 src/documents/tasks.py | 12 ++++++++----
 1 file changed, 8 insertions(+), 4 deletions(-)

diff --git a/src/documents/tasks.py b/src/documents/tasks.py
index 56c2d92f1..bd5199359 100644
--- a/src/documents/tasks.py
+++ b/src/documents/tasks.py
@@ -346,10 +346,14 @@ def empty_trash(doc_ids=None):
 
 @shared_task
 def check_scheduled_workflows():
-    scheduled_workflows: list[Workflow] = Workflow.objects.filter(
-        triggers__type=WorkflowTrigger.WorkflowTriggerType.SCHEDULED,
-        enabled=True,
-    ).prefetch_related("triggers")
+    scheduled_workflows: list[Workflow] = (
+        Workflow.objects.filter(
+            triggers__type=WorkflowTrigger.WorkflowTriggerType.SCHEDULED,
+            enabled=True,
+        )
+        .distinct()
+        .prefetch_related("triggers")
+    )
     if scheduled_workflows.count() > 0:
         logger.debug(f"Checking {len(scheduled_workflows)} scheduled workflows")
         for workflow in scheduled_workflows: