Skip to content

Commit

Permalink
functional tests fixups
Browse files Browse the repository at this point in the history
Issue: BB-585
  • Loading branch information
benzekrimaha committed Jan 16, 2025
1 parent 49d3f13 commit ab81bc9
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 deletions.
2 changes: 1 addition & 1 deletion tests/functional/lib/BackbeatConsumer.js
Original file line number Diff line number Diff line change
Expand Up @@ -124,7 +124,7 @@ describe('BackbeatConsumer main tests', () => {
setTimeout(() => {
_checkZkMetrics(() => {
consumeCb();
consumer.unsubscribe();
consumer._consumer.unsubscribe();
});
}, 5000);
assert.deepStrictEqual(
Expand Down
8 changes: 4 additions & 4 deletions tests/unit/lifecycle/LifecycleConductor.spec.js
Original file line number Diff line number Diff line change
Expand Up @@ -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);
});
});

Expand Down

0 comments on commit ab81bc9

Please sign in to comment.