diff --git a/server/queues/tasks/ImportMarkdownZipTask.ts b/server/queues/tasks/ImportMarkdownZipTask.ts
index 819591884..4053619fd 100644
--- a/server/queues/tasks/ImportMarkdownZipTask.ts
+++ b/server/queues/tasks/ImportMarkdownZipTask.ts
@@ -71,7 +71,7 @@ export default class ImportMarkdownZipTask extends ImportTask {
               name: child.name,
               path: child.path,
               mimeType: mime.lookup(child.path) || "application/octet-stream",
-              buffer: await zipObject.async("nodebuffer"),
+              buffer: () => zipObject.async("nodebuffer"),
             });
             return;
           }
diff --git a/server/queues/tasks/ImportNotionTask.ts b/server/queues/tasks/ImportNotionTask.ts
index 3607cf740..bcbaa8c25 100644
--- a/server/queues/tasks/ImportNotionTask.ts
+++ b/server/queues/tasks/ImportNotionTask.ts
@@ -82,7 +82,7 @@ export default class ImportNotionTask extends ImportTask {
               name: child.name,
               path: child.path,
               mimeType,
-              buffer: await zipObject.async("nodebuffer"),
+              buffer: () => zipObject.async("nodebuffer"),
               sourceId,
             });
             return;
diff --git a/server/queues/tasks/ImportTask.ts b/server/queues/tasks/ImportTask.ts
index 0c2091b42..03323368a 100644
--- a/server/queues/tasks/ImportTask.ts
+++ b/server/queues/tasks/ImportTask.ts
@@ -66,7 +66,7 @@ export type StructuredImportData = {
     name: string;
     path: string;
     mimeType: string;
-    buffer: Buffer;
+    buffer: () => Promise<Buffer>;
     /** Optional id from import source, useful for mapping */
     sourceId?: string;
   }[];
@@ -215,7 +215,7 @@ export default abstract class ImportTask extends BaseTask<Props> {
             id: item.id,
             name: item.name,
             type: item.mimeType,
-            buffer: item.buffer,
+            buffer: await item.buffer(),
             user,
             ip,
             transaction,