actions
/
toolkit
mirror of https://github.com/actions/toolkit
1
0
Fork 0
Code

adding queue back

pull/1700/head
Vallie Joseph 2024-04-01 20:04:49 +00:00
parent a2a8a724c2
commit a926fff385
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
packages/artifact/src/internal/upload/zip.ts
View File

@ -84,7 +84,10 @@ export async function createZipUploadStream(
// }) // })
// } // }
// see https://caolan.github.io/async/v3/docs.html#queue for options // see https://caolan.github.io/async/v3/docs.html#queue for options
const fileUploadQueue = async.queue() // concurrency for uploads automatically set to 1 const fileUploadQueue = async.queue(function (task, callback) {
core.debug(`adding file to upload queue ${task}`)
callback()
}) // concurrency for uploads automatically set to 1
fileUploadQueue.error(function (err, task) { fileUploadQueue.error(function (err, task) {
core.error(`task experienced an error: ${task} ${err}`) core.error(`task experienced an error: ${task} ${err}`)
@ -127,7 +130,6 @@ export async function createZipUploadStream(
fileUploadQueue.drain(() => { fileUploadQueue.drain(() => {
core.debug('all items have been processed') core.debug('all items have been processed')
}) })
zip.finalize() zip.finalize()
core.debug(`Finalizing entries`) core.debug(`Finalizing entries`)
const bufferSize = getUploadChunkSize() const bufferSize = getUploadChunkSize()