Skip to content

Commit 7f30a63

Browse files
benzekrimahaKerkesni
authored andcommitted
functional tests fixups
Issue: BB-585
1 parent ccb4f45 commit 7f30a63

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

tests/functional/lib/BackbeatConsumer.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -124,7 +124,7 @@ describe('BackbeatConsumer main tests', () => {
124124
setTimeout(() => {
125125
_checkZkMetrics(() => {
126126
consumeCb();
127-
consumer.unsubscribe();
127+
consumer._consumer.unsubscribe();
128128
});
129129
}, 5000);
130130
assert.deepStrictEqual(

tests/unit/lifecycle/LifecycleConductor.spec.js

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -242,19 +242,19 @@ describe('Lifecycle Conductor', () => {
242242
});
243243

244244
describe('_indexesGetOrCreate', () => {
245-
it('should return v1 for bucketd bucket sources', () => {
245+
it('should return v2 for bucketd bucket sources', () => {
246246
conductor._bucketSource = 'bucketd';
247247
conductor._indexesGetOrCreate(testTask, log, (err, taskVersion) => {
248248
assert.ifError(err);
249-
assert.deepStrictEqual(taskVersion, lifecycleTaskVersions.v1);
249+
assert.deepStrictEqual(taskVersion, lifecycleTaskVersions.v2);
250250
});
251251
});
252252

253-
it('should return v1 for zookeeper bucket sources', () => {
253+
it('should return v2 for zookeeper bucket sources', () => {
254254
conductor._bucketSource = 'zookeeper';
255255
conductor._indexesGetOrCreate(testTask, log, (err, taskVersion) => {
256256
assert.ifError(err);
257-
assert.deepStrictEqual(taskVersion, lifecycleTaskVersions.v1);
257+
assert.deepStrictEqual(taskVersion, lifecycleTaskVersions.v2);
258258
});
259259
});
260260

0 commit comments

Comments
 (0)