fix

denodrivers · Nov 4, 2024 · 82918d1 · 82918d1
1 parent 503e59f
commit 82918d1
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/experimental/cluster/mod.ts b/experimental/cluster/mod.ts
@@ -296,7 +296,7 @@ class ClusterExecutor implements CommandExecutor {
   async #closeExistingConnection() {
     const nodeNames = Object.keys(this.#connectionByNodeName);
     while (nodeNames.length >= this.#maxConnections) {
-      const nodeName = sample(nodeNames);
+      const nodeName = sample(nodeNames)!;
       const conn = this.#connectionByNodeName[nodeName];
       delete this.#connectionByNodeName[nodeName];
       try {

diff --git a/tests/cluster/test.ts b/tests/cluster/test.ts
@@ -88,7 +88,7 @@ describe("experimental/cluster", () => {
               const slot = calculateSlot(key);
               manuallyRedirectedPort = sample(
                 ports.filter((x) => x !== opts.port),
-              );
+              )!;
               const error = new ErrorReplyError(
                 `-MOVED ${slot} ${opts.hostname}:${manuallyRedirectedPort}`,
               );
@@ -147,7 +147,7 @@ describe("experimental/cluster", () => {
               const slot = calculateSlot(key);
               manuallyRedirectedPort = sample(
                 ports.filter((x) => x !== opts.port),
-              );
+              )!;
               const error = new ErrorReplyError(
                 `-ASK ${slot} ${opts.hostname}:${manuallyRedirectedPort}`,
               );