diff --git a/packages/server/services/files/file.service.js b/packages/server/services/files/file.service.js
index 5569301b..0e0db8b2 100755
--- a/packages/server/services/files/file.service.js
+++ b/packages/server/services/files/file.service.js
@@ -30,9 +30,12 @@ class API extends Server {
 		limits: {},
 	}
 
-	queuesManager = new TaskQueueManager({
-		workersPath: `${__dirname}/queues`,
-	})
+	queuesManager = new TaskQueueManager(
+		{
+			workersPath: `${__dirname}/queues`,
+		},
+		this,
+	)
 
 	async onInitialize() {
 		global.sse = this.contexts.SSEManager
diff --git a/packages/server/services/files/queues/TransmuxedUpload/index.js b/packages/server/services/files/queues/TransmuxedUpload/index.js
index c3cba0ff..18b2d029 100644
--- a/packages/server/services/files/queues/TransmuxedUpload/index.js
+++ b/packages/server/services/files/queues/TransmuxedUpload/index.js
@@ -29,7 +29,7 @@ export default {
 				transmuxOptions: transmuxOptions,
 				cachePath: cachePath,
 				onProgress: (progress) => {
-					job.progress(progress)
+					job.updateProgress(progress)
 				},
 			})
 
diff --git a/packages/server/services/files/routes/upload/chunk/post.js b/packages/server/services/files/routes/upload/chunk/post.js
index f7a62a57..9a7c9a90 100644
--- a/packages/server/services/files/routes/upload/chunk/post.js
+++ b/packages/server/services/files/routes/upload/chunk/post.js
@@ -60,15 +60,21 @@ export default {
 
 				if (req.headers["transmux"] || limits.useCompression === true) {
 					// add a background task
-					const job = await global.queues.createJob("remote_upload", {
-						filePath: build.filePath,
-						parentDir: req.auth.session.user_id,
-						service: limits.useProvider,
-						useCompression: limits.useCompression,
-						transmux: req.headers["transmux"] ?? false,
-						transmuxOptions: req.headers["transmux-options"],
-						cachePath: tmpPath,
-					})
+					const job = await global.queues.createJob(
+						"remote_upload",
+						{
+							filePath: build.filePath,
+							parentDir: req.auth.session.user_id,
+							service: limits.useProvider,
+							useCompression: limits.useCompression,
+							transmux: req.headers["transmux"] ?? false,
+							transmuxOptions: req.headers["transmux-options"],
+							cachePath: tmpPath,
+						},
+						{
+							useSSE: true,
+						},
+					)
 
 					const sseChannelId = job.sseChannelId