diff --git a/src/libs/tasks/queueTask.ts b/src/libs/tasks/queueTask.ts index fecefd6..4758c09 100644 --- a/src/libs/tasks/queueTask.ts +++ b/src/libs/tasks/queueTask.ts @@ -78,25 +78,16 @@ export async function queueTask( .digest("hex"), ); console.log(hashedTaskName); - console.log( - { - ...task, - name: hashedTaskName, - }, - { - ...task, - name: - task.name.split("/").slice(0, -1).join("/") + - "/" + - hashedTaskName, - }, - ); const { res } = await queueCloudTask({ ...task, name: task.name.split("/").slice(0, -1).join("/") + "/" + hashedTaskName, }); if (!res.ok) { + if (await checkIfTaskExists(env, queueName, hashedTaskName, body)) { + return; + } + throw new FailedToQueueTaskError(res.status, await res.text()); } }