From 734ce25aa27ee4306730aaf5bc3b801685bc0717 Mon Sep 17 00:00:00 2001 From: Rushil Perera Date: Fri, 19 Dec 2025 05:11:12 -0500 Subject: [PATCH] fix: Invert conditional logic for Cloudflare task queueing based on environment presence. --- src/libs/tasks/queueTask.ts | 24 ++++++++++++------------ 1 file changed, 12 insertions(+), 12 deletions(-) diff --git a/src/libs/tasks/queueTask.ts b/src/libs/tasks/queueTask.ts index 93d0671..ec9c93d 100644 --- a/src/libs/tasks/queueTask.ts +++ b/src/libs/tasks/queueTask.ts @@ -79,7 +79,18 @@ export async function queueTask( // Otherwise, queue directly const contentType = headers["Content-Type"] === "application/json" ? "json" : "text"; - if (!env) { + if (env) { + console.debug( + `Queueing task in queue ${queueName}: ${JSON.stringify(body)}`, + ); + await env[queueName].send( + { body, headers }, + { + contentType, + delaySeconds: scheduleTime, + }, + ); + } else { const Cloudflare = await import("cloudflare").then( ({ Cloudflare }) => Cloudflare, ); @@ -103,17 +114,6 @@ export async function queueTask( delay_seconds: scheduleTime, account_id: env.CLOUDFLARE_ACCOUNT_ID, }); - } else { - console.debug( - `Queueing task in queue ${queueName}: ${JSON.stringify(body)}`, - ); - await env[queueName].send( - { body, headers }, - { - contentType, - delaySeconds: scheduleTime, - }, - ); } } function buildTask(