From 44c9d579833468edef820315d85e4a62da0f72e0 Mon Sep 17 00:00:00 2001
From: Maha Benzekri <maha.benzekri@scality.com>
Date: Wed, 15 Jan 2025 13:59:37 +0100
Subject: [PATCH] functional tests fixups

---
 tests/functional/lib/BackbeatConsumer.js        | 2 +-
 tests/unit/lifecycle/LifecycleConductor.spec.js | 8 ++++----
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/tests/functional/lib/BackbeatConsumer.js b/tests/functional/lib/BackbeatConsumer.js
index ca374d6e6..f4de62c59 100644
--- a/tests/functional/lib/BackbeatConsumer.js
+++ b/tests/functional/lib/BackbeatConsumer.js
@@ -124,7 +124,7 @@ describe('BackbeatConsumer main tests', () => {
                 setTimeout(() => {
                     _checkZkMetrics(() => {
                         consumeCb();
-                        consumer.unsubscribe();
+                        consumer._consumer.unsubscribe();
                     });
                 }, 5000);
                 assert.deepStrictEqual(
diff --git a/tests/unit/lifecycle/LifecycleConductor.spec.js b/tests/unit/lifecycle/LifecycleConductor.spec.js
index 31ba588c5..f83a6984e 100644
--- a/tests/unit/lifecycle/LifecycleConductor.spec.js
+++ b/tests/unit/lifecycle/LifecycleConductor.spec.js
@@ -242,19 +242,19 @@ describe('Lifecycle Conductor', () => {
     });
 
     describe('_indexesGetOrCreate', () => {
-        it('should return v1 for bucketd bucket sources', () => {
+        it('should return v2 for bucketd bucket sources', () => {
             conductor._bucketSource = 'bucketd';
             conductor._indexesGetOrCreate(testTask, log, (err, taskVersion) => {
                 assert.ifError(err);
-                assert.deepStrictEqual(taskVersion, lifecycleTaskVersions.v1);
+                assert.deepStrictEqual(taskVersion, lifecycleTaskVersions.v2);
             });
         });
 
-        it('should return v1 for zookeeper bucket sources', () => {
+        it('should return v2 for zookeeper bucket sources', () => {
             conductor._bucketSource = 'zookeeper';
             conductor._indexesGetOrCreate(testTask, log, (err, taskVersion) => {
                 assert.ifError(err);
-                assert.deepStrictEqual(taskVersion, lifecycleTaskVersions.v1);
+                assert.deepStrictEqual(taskVersion, lifecycleTaskVersions.v2);
             });
         });