Skip to content

Commit 17a2fde

Browse files
authored
chore: allow clientBulkWrite to use TimeoutContext (#4251)
1 parent 5aa6d4c commit 17a2fde

File tree

1 file changed

+10
-2
lines changed

1 file changed

+10
-2
lines changed

src/operations/client_bulk_write/client_bulk_write.ts

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@ import { type Document } from 'bson';
33
import { ClientBulkWriteCursorResponse } from '../../cmap/wire_protocol/responses';
44
import type { Server } from '../../sdam/server';
55
import type { ClientSession } from '../../sessions';
6+
import { type TimeoutContext } from '../../timeout';
67
import { MongoDBNamespace } from '../../utils';
78
import { CommandOperation } from '../command';
89
import { Aspect, defineAspects } from '../operation';
@@ -35,9 +36,16 @@ export class ClientBulkWriteOperation extends CommandOperation<ClientBulkWriteCu
3536
*/
3637
override async execute(
3738
server: Server,
38-
session: ClientSession | undefined
39+
session: ClientSession | undefined,
40+
timeoutContext: TimeoutContext
3941
): Promise<ClientBulkWriteCursorResponse> {
40-
return await super.executeCommand(server, session, this.command, ClientBulkWriteCursorResponse);
42+
return await super.executeCommand(
43+
server,
44+
session,
45+
this.command,
46+
timeoutContext,
47+
ClientBulkWriteCursorResponse
48+
);
4149
}
4250
}
4351

0 commit comments

Comments
 (0)