fix(.join): deprecation

deprecation
Comfy-Org · Jan 20, 2025 · 3cced0c · 3cced0c
1 parent 6506807
commit 3cced0c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/EmailTasks.ts b/src/EmailTasks.ts
@@ -65,7 +65,7 @@ export async function enqueueEmailTask(task: z.infer<typeof zSendEmailAction>) {
 }
 export async function updateEmailTasks() {
   const count = await sf(EmailTasks.find({ state: "waiting" }))
-    .join(sf(EmailTasks.find({ state: "sending", mtime: $stale("1m") })))
+    .merge(sf(EmailTasks.find({ state: "sending", mtime: $stale("1m") })))
     .map(async (e) => {
       const { _id, state } = e;
       if (state === "waiting") {