Skip to content

Commit 69502a1

Browse files
committed
Fix CSOT unified spec tests.
1 parent 9eca4f4 commit 69502a1

File tree

4 files changed

+564
-547
lines changed

4 files changed

+564
-547
lines changed

mongo/change_stream.go

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -139,15 +139,6 @@ func newChangeStream(ctx context.Context, config changeStreamConfig, pipeline in
139139
CommandMonitor(cs.client.monitor).Session(cs.sess).ServerSelector(cs.selector).Retry(driver.RetryNone).
140140
ServerAPI(cs.client.serverAPI).Crypt(config.crypt).Timeout(cs.client.timeout)
141141

142-
// Omit "maxTimeMS" from operations that return a user-managed cursor to
143-
// prevent confusing "cursor not found" errors. To maintain existing
144-
// behavior for users who set "timeoutMS" with no context deadline, only
145-
// omit "maxTimeMS" when a context deadline is set.
146-
//
147-
// See DRIVERS-2722 for more detail.
148-
_, deadlineSet := ctx.Deadline()
149-
cs.aggregate.OmitCSOTMaxTimeMS(deadlineSet)
150-
151142
if cs.options.Collation != nil {
152143
cs.aggregate.Collation(bsoncore.Document(cs.options.Collation.ToDocument()))
153144
}

0 commit comments

Comments
 (0)