Fix async drain function not writable anymore

scality · Nov 8, 2024 · fb7708e · fb7708e
1 parent 00e5091
commit fb7708e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/lib/tasks/TaskScheduler.js b/lib/tasks/TaskScheduler.js
@@ -33,7 +33,9 @@ class TaskScheduler {
 
     _getNewTaskQueue(ctx, queueKey) {
         const queue = async.queue(this._processingFunc);
-        queue.drain = () => delete this._taskQueues[queueKey];
+        queue.drain(() => {
+            delete this._taskQueues[queueKey];
+        });
         this._taskQueues[queueKey] = queue;
         return queue;
     }

diff --git a/tests/unit/lib/tasks/TaskScheduler.spec.js b/tests/unit/lib/tasks/TaskScheduler.spec.js
@@ -2,7 +2,7 @@ const assert = require('assert');
 
 const TaskScheduler = require('../../../../lib/tasks/TaskScheduler');
 
-describe('TaskScheduler', () => {
+describe.only('TaskScheduler', () => {
     it('should ensure serialization of updates with the same queue key',
     done => {
         const taskScheduler = new TaskScheduler(