Skip to content

Commit

Permalink
Signed-off-by: Yury-Fridlyand <yury.fridlyand@improving.com>
Browse files Browse the repository at this point in the history
  • Loading branch information
Yury-Fridlyand committed Sep 18, 2024
1 parent 59cfa7f commit 68c9e5f
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 13 deletions.
2 changes: 1 addition & 1 deletion .github/json_matrices/engine-matrix.json
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,6 @@
},
{
"type": "valkey",
"version": "8.0.0-rc1"
"version": "8.0.0"
}
]
20 changes: 8 additions & 12 deletions node/tests/PubSub.test.ts
Original file line number Diff line number Diff line change
Expand Up @@ -4018,7 +4018,7 @@ describe("PubSub", () => {
*
* @param clusterMode - Indicates if the test should be run in cluster mode.
*/
it.each([true, false])(
it.each([true])(
"test pubsub numsub and shardnumsub separation_%p",
async (clusterMode) => {
//const clusterMode = false;
Expand Down Expand Up @@ -4070,17 +4070,13 @@ describe("PubSub", () => {
});

// Test pubsubShardnumsub
if (clusterMode) {
const shardSubscribers = await (
client2 as GlideClusterClient
).pubsubShardNumSub([regularChannel, shardChannel]);
expect(
convertGlideRecordToRecord(shardSubscribers),
).toEqual({
[regularChannel]: 0,
[shardChannel]: 2,
});
}
const shardSubscribers = await (
client2 as GlideClusterClient
).pubsubShardNumSub([regularChannel, shardChannel]);
expect(convertGlideRecordToRecord(shardSubscribers)).toEqual({
[regularChannel]: 0,
[shardChannel]: 2,
});
} finally {
if (client1) {
await clientCleanup(client1, pubSub!);
Expand Down

0 comments on commit 68c9e5f

Please sign in to comment.