diff --git a/packages/artifact/src/internal/upload/zip.ts b/packages/artifact/src/internal/upload/zip.ts
index dae88d9a..4ac9b0e2 100644
--- a/packages/artifact/src/internal/upload/zip.ts
+++ b/packages/artifact/src/internal/upload/zip.ts
@@ -22,7 +22,26 @@ export class ZipUploadStream extends stream.Transform {
     cb(null, chunk)
   }
 }
-
+export async function zipFileUpload(file, zip, callback): Promise<void> {
+  const readStream = createReadStream(file.sourcePath)
+  if (file.sourcePath !== null) {
+    zip.entry(readStream, {name: file.destinationPath}, function (err) {
+      core.debug(`Is stream paused: ${readStream.isPaused()}`)
+      if (err) {
+        core.error('An error occurred:', err)
+        return callback(err)
+      }
+      core.debug(`Is stream paused: ${readStream.isPaused()}`)
+    })
+  } else {
+    zip.entry(null, {name: `${file.destinationPath}/`}, function (err) {
+      if (err) {
+        core.error('An error occurred:', err)
+      }
+    })
+  }
+  callback()
+}
 export async function createZipUploadStream(
   uploadSpecification: UploadZipSpecification[],
   compressionLevel: number = DEFAULT_COMPRESSION_LEVEL
@@ -83,51 +102,55 @@ export async function createZipUploadStream(
   //     }
   //   })
   // }
-  const fileUploadQueue = async.queue(function (task, callback) {
-    core.debug(`adding file to upload queue ${task}`)
-    callback()
-  }, 1)
+  // see https://caolan.github.io/async/v3/docs.html#queue for options
+  // const fileUploadQueue = async.queue() // concurrency for uploads automatically set to 1
 
-  fileUploadQueue.error(function (err, task) {
-    core.error(`task experienced an error: ${task} ${err}`)
-  })
+  // fileUploadQueue.error(function (err, task) {
+  //   core.error(`task experienced an error: ${task} ${err}`)
+  // })
 
-  for (const file of uploadSpecification) {
-    if (file.sourcePath !== null) {
-      const readStream = createReadStream(file.sourcePath)
-      readStream.on('data', chunk => {
-        core.debug(`Received ${chunk.length} bytes of data.`)
-      })
-      readStream.on('end', () => {
-        core.debug('There will be no more data.')
-      })
-      readStream.on('error', function (err) {
-        core.debug(`${err}`)
-      }) // Catch any errors from createReadStream
-      fileUploadQueue.push(
-        zip.entry(readStream, {name: file.destinationPath}, function (err) {
-          core.debug(`Is stream paused: ${readStream.isPaused()}`)
-          if (err) {
-            core.error('An error occurred:', err)
-          }
-          core.debug(`Is stream paused: ${readStream.isPaused()}`)
-        })
-      )
-    } else {
-      fileUploadQueue.push(
-        zip.entry(null, {name: `${file.destinationPath}/`}, function (err) {
-          if (err) {
-            core.error('An error occurred:', err)
-          }
-        })
-      )
+  // for (const file of uploadSpecification) {
+  //   if (file.sourcePath !== null) {
+  //     const readStream = createReadStream(file.sourcePath)
+  //     readStream.on('data', chunk => {
+  //       core.debug(`Received ${chunk.length} bytes of data.`)
+  //     })
+  //     readStream.on('end', () => {
+  //       core.debug('There will be no more data.')
+  //     })
+  //     readStream.on('error', function (err) {
+  //       core.debug(`${err}`)
+  //     }) // Catch any errors from createReadStream
+  //     fileUploadQueue.push(
+  //       zip.entry(readStream, {name: file.destinationPath}, function (err) {
+  //         core.debug(`Is stream paused: ${readStream.isPaused()}`)
+  //         if (err) {
+  //           core.error('An error occurred:', err)
+  //         }
+  //         core.debug(`Is stream paused: ${readStream.isPaused()}`)
+  //       })
+  //     )
+  //   } else {
+  //     fileUploadQueue.push(
+  //       zip.entry(null, {name: `${file.destinationPath}/`}, function (err) {
+  //         if (err) {
+  //           core.error('An error occurred:', err)
+  //         }
+  //       })
+  //     )
+  //   }
+  // }
+
+  // core.debug(`Starting the finalizing of all entries`)
+
+  // fileUploadQueue.drain(() => {
+  //   core.debug('all items have been processed')
+  // })
+
+  async.forEachOf(uploadSpecification, zipFileUpload, function (err) {
+    if (err) {
+      core.error('An error occurred:', err)
     }
-  }
-
-  core.debug(`Starting the finalizing of all entries`)
-
-  fileUploadQueue.drain(() => {
-    core.debug('all items have been processed')
   })
   zip.finalize()
   core.debug(`Finalizing entries`)