diff --git a/tests/Operation/WatchFunctionalTest.php b/tests/Operation/WatchFunctionalTest.php
index deb9d976d..9dc0acff1 100644
--- a/tests/Operation/WatchFunctionalTest.php
+++ b/tests/Operation/WatchFunctionalTest.php
@@ -18,6 +18,7 @@
 use MongoDB\Driver\Exception\ServerException;
 use MongoDB\Driver\Monitoring\CommandSucceededEvent;
 use MongoDB\Driver\ReadPreference;
+use MongoDB\Driver\Server;
 use MongoDB\Driver\WriteConcern;
 use MongoDB\Exception\ResumeTokenException;
 use MongoDB\Exception\UnsupportedValueException;
@@ -1371,10 +1372,10 @@ public function testOriginalReadPreferenceIsPreservedOnResume(): void
 
         $changeStream = $operation->execute($secondary);
         $previousCursorId = $changeStream->getCursorId(true);
-        $this->forceChangeStreamResume();
+        $this->forceChangeStreamResume($secondary);
 
         $changeStream->next();
-        $this->assertNotSame($previousCursorId, $changeStream->getCursorId(true));
+        $this->assertNotEquals($previousCursorId, $changeStream->getCursorId(true));
 
         $getCursor = Closure::bind(
             fn () => $this->iterator->getInnerIterator(),
@@ -1611,17 +1612,20 @@ function (array $event) use (&$commands): void {
         $this->assertEmpty($commands);
     }
 
-    private function forceChangeStreamResume(): void
+    private function forceChangeStreamResume(?Server $server = null): void
     {
-        $this->configureFailPoint([
-            'configureFailPoint' => 'failCommand',
-            'mode' => ['times' => 1],
-            'data' => [
-                'failCommands' => ['getMore'],
-                'errorCode' => self::NOT_PRIMARY,
-                'errorLabels' => ['ResumableChangeStreamError'],
+        $this->configureFailPoint(
+            [
+                'configureFailPoint' => 'failCommand',
+                'mode' => ['times' => 1],
+                'data' => [
+                    'failCommands' => ['getMore'],
+                    'errorCode' => self::NOT_PRIMARY,
+                    'errorLabels' => ['ResumableChangeStreamError'],
+                ],
             ],
-        ]);
+            $server,
+        );
     }
 
     private function getPostBatchResumeTokenFromReply(stdClass $reply)