diff --git a/.changeset/tall-carpets-own.md b/.changeset/tall-carpets-own.md new file mode 100644 index 000000000..ced453690 --- /dev/null +++ b/.changeset/tall-carpets-own.md @@ -0,0 +1,5 @@ +--- +"@opennextjs/aws": patch +--- + +Improve error handling in Writable stream in cloudflare node converters diff --git a/packages/open-next/src/overrides/wrappers/cloudflare-node.ts b/packages/open-next/src/overrides/wrappers/cloudflare-node.ts index ac121be70..d706e91f1 100644 --- a/packages/open-next/src/overrides/wrappers/cloudflare-node.ts +++ b/packages/open-next/src/overrides/wrappers/cloudflare-node.ts @@ -83,7 +83,11 @@ const handler: WrapperHandler = return new Writable({ write(chunk, encoding, callback) { - controller.enqueue(chunk); + try { + controller.enqueue(chunk); + } catch (e: any) { + return callback(e); + } callback(); }, final(callback) {