Skip to content

Commit 09aa41b

Browse files
authored
PYTHON-6013 Consolidate session/transaction helpers into a shared file (#3019)
1 parent ee90d3c commit 09aa41b

17 files changed

Lines changed: 459 additions & 738 deletions

‎pymongo/asynchronous/bulk.py‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@
3333
from bson.raw_bson import RawBSONDocument
3434
from pymongo import _csot, common
3535
from pymongo._telemetry import _generate_op_id_or_none
36-
from pymongo.asynchronous.client_session import AsyncClientSession, _validate_session_write_concern
36+
from pymongo.asynchronous.client_session import AsyncClientSession
3737
from pymongo.asynchronous.command_runner import (
3838
run_bulk_write_command,
3939
)
@@ -45,6 +45,7 @@
4545
_raise_bulk_write_error,
4646
_Run,
4747
)
48+
from pymongo.client_session_shared import _validate_session_write_concern
4849
from pymongo.common import (
4950
validate_is_document_type,
5051
validate_ok_for_replace,

‎pymongo/asynchronous/client_bulk.py‎

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -33,10 +33,7 @@
3333
from bson.raw_bson import RawBSONDocument
3434
from pymongo import _csot, common
3535
from pymongo._telemetry import _generate_op_id_or_none
36-
from pymongo.asynchronous.client_session import (
37-
AsyncClientSession,
38-
_validate_session_write_concern,
39-
)
36+
from pymongo.asynchronous.client_session import AsyncClientSession
4037
from pymongo.asynchronous.collection import AsyncCollection
4138
from pymongo.asynchronous.command_cursor import AsyncCommandCursor
4239
from pymongo.asynchronous.command_runner import (
@@ -52,6 +49,7 @@
5249
_merge_command,
5350
_throw_client_bulk_write_exception,
5451
)
52+
from pymongo.client_session_shared import _validate_session_write_concern
5553
from pymongo.common import (
5654
validate_is_document_type,
5755
validate_ok_for_replace,

0 commit comments

Comments
 (0)