fixup

scality · Dec 11, 2024 · 43363f4 · 43363f4
1 parent 63902fb
commit 43363f4
Showing 1 changed file with 5 additions and 9 deletions.
diff --git a/tests/functional/ingestion/IngestionReader.js b/tests/functional/ingestion/IngestionReader.js
@@ -249,8 +249,10 @@ describe('ingestion reader tests with mock', function fD() {
                     next => zkClient.setData(
                         this.ingestionReader.pathToLogOffset,
                         Buffer.from(mockLogOffset.toString()), -1, err => {
-                            assert.ifError(err);
-                            return next(err);  // Important to call next() here
+                            if (err) {
+                                return next(err);
+                            }
+                            return next();
                         }
                     ),
                     next => setupS3Mock(sourceConfig, next),
@@ -262,17 +264,11 @@ describe('ingestion reader tests with mock', function fD() {
                 });
             });
         });
-
         afterEach(done => {
             async.series([
                 next => emptyAndDeleteVersionedBucket(sourceConfig, next),
                 next => zkClient.remove(this.ingestionReader.pathToLogOffset, -1, next),
-            ], err => {
-                if (err) {
-                    return done(err);
-                }
-                return done();
-            });
+            ], done);
         });
 
         it('_processReadRecords should retrieve logRes stream', done => {