Skip to content

Commit cdeff1d

Browse files
committed
Work around flaky change stream test failures on mongos
This skips one test, which immediately fails on mongos due to a socket timeout on the initial aggregate. Additionally, this bumps the number of getMore attempts for advanceCursorUntilValid.
1 parent b1aa520 commit cdeff1d

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

tests/Operation/WatchFunctionalTest.php

+3-1
Original file line numberDiff line numberDiff line change
@@ -156,6 +156,8 @@ function (array $event) use (&$lastEvent) {
156156

157157
public function testNextResumesAfterConnectionException()
158158
{
159+
$this->skipIfIsShardedCluster('initial aggregate command times out due to socketTimeoutMS');
160+
159161
/* In order to trigger a dropped connection, we'll use a new client with
160162
* a socket timeout that is less than the change stream's maxAwaitTimeMS
161163
* option. */
@@ -1600,7 +1602,7 @@ private function isStartAtOperationTimeSupported()
16001602
return server_supports_feature($this->getPrimaryServer(), self::$wireVersionForStartAtOperationTime);
16011603
}
16021604

1603-
private function advanceCursorUntilValid(Iterator $iterator, $limitOnShardedClusters = 5)
1605+
private function advanceCursorUntilValid(Iterator $iterator, $limitOnShardedClusters = 10)
16041606
{
16051607
if (! $this->isShardedCluster()) {
16061608
$iterator->next();

0 commit comments

Comments
 (0)