Use group-by to ensure no duplicate jobs

Author: TheodoreSpeaks

apps/sim/lib/billing/cleanup-dispatcher.ts

@@ -91,6 +91,7 @@ export async function resolveWorkspaceIdsForPlan(plan: NonEnterprisePlan): Promi
       )
     )
     .where(isNull(workspace.archivedAt))
+    .groupBy(workspace.id)
 
   return rows.map((r) => r.id)
 }
@@ -210,7 +211,10 @@ export async function dispatchCleanupJobs(
     await runInlineIfNeeded(jobQueue, jobType, jobId, payload)
   }
 
-  // Enterprise: query workspaces with non-NULL retention column
+  // Enterprise: query workspaces with non-NULL retention column. The JOIN can
+  // match multiple subscription rows per workspace (e.g. active + past_due both
+  // in ENTITLED_SUBSCRIPTION_STATUSES) — groupBy dedupes to one row per workspace
+  // so we don't dispatch the same cleanup job twice.
   const retentionCol = workspace[config.column]
   const enterpriseRows = await db
     .select({ id: workspace.id })
@@ -224,6 +228,7 @@ export async function dispatchCleanupJobs(
       )
     )
     .where(and(isNull(workspace.archivedAt), isNotNull(retentionCol)))
+    .groupBy(workspace.id)
 
   const enterpriseCount = enterpriseRows.length