Skip to content

Commit b3bf0b9

Browse files
committed
Merge branch 'master' of github.com:mongodb/mongo-python-driver
2 parents 48ddb1f + 9d2a1ce commit b3bf0b9

File tree

7 files changed

+19
-13
lines changed

7 files changed

+19
-13
lines changed

.evergreen/run-tests.sh

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -254,11 +254,6 @@ if [ -n "$COVERAGE" ] && [ "$PYTHON_IMPL" = "CPython" ]; then
254254
fi
255255

256256
if [ -n "$GREEN_FRAMEWORK" ]; then
257-
# Install all optional deps to ensure lazy imports are getting patched.
258-
python -m pip install -q ".[aws,encryption,gssapi,ocsp,snappy,zstd]"
259-
if [ "$OLD_PYPY" == "True" ]; then
260-
pip install "python-snappy<0.7.0"
261-
fi
262257
python -m pip install $GREEN_FRAMEWORK
263258
fi
264259

test/__init__.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -129,6 +129,9 @@
129129
}
130130
KMIP_CREDS = {"endpoint": os.environ.get("FLE_KMIP_ENDPOINT", "localhost:5698")}
131131

132+
# Ensure Evergreen metadata doesn't result in truncation
133+
os.environ.setdefault("MONGOB_LOG_MAX_DOCUMENT_LENGTH", "2000")
134+
132135

133136
def is_server_resolvable():
134137
"""Returns True if 'server' is resolvable."""

test/connection_logging/connection-pool-options.json

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -300,7 +300,6 @@
300300
},
301301
{
302302
"description": "waitQueueSize should be included in connection pool created message when specified",
303-
"skipReason": "PyMongo does not support waitQueueSize",
304303
"operations": [
305304
{
306305
"name": "createEntities",
@@ -379,7 +378,6 @@
379378
},
380379
{
381380
"description": "waitQueueMultiple should be included in connection pool created message when specified",
382-
"skipReason": "PyMongo does not support waitQueueMultiple",
383381
"operations": [
384382
{
385383
"name": "createEntities",
@@ -457,4 +455,4 @@
457455
]
458456
}
459457
]
460-
}
458+
}

test/connection_monitoring/pool-checkout-maxConnecting-is-enforced.json

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919
],
2020
"closeConnection": false,
2121
"blockConnection": true,
22-
"blockTimeMS": 750
22+
"blockTimeMS": 800
2323
}
2424
},
2525
"poolOptions": {
@@ -53,7 +53,7 @@
5353
},
5454
{
5555
"name": "wait",
56-
"ms": 100
56+
"ms": 400
5757
},
5858
{
5959
"name": "checkOut",

test/test_command_logging.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,8 +26,6 @@
2626
# Location of JSON test specifications.
2727
_TEST_PATH = os.path.join(os.path.dirname(os.path.realpath(__file__)), "command_logging")
2828

29-
os.environ["MONGOB_LOG_MAX_DOCUMENT_LENGTH"] = "2000"
30-
3129
globals().update(
3230
generate_test_classes(
3331
_TEST_PATH,

test/test_transactions_unified.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,9 +20,15 @@
2020

2121
sys.path[0:0] = [""]
2222

23-
from test import unittest
23+
from test import client_context, unittest
2424
from test.unified_format import generate_test_classes
2525

26+
27+
@client_context.require_no_mmap
28+
def setUpModule():
29+
pass
30+
31+
2632
# Location of JSON test specifications.
2733
TEST_PATH = os.path.join(os.path.dirname(os.path.realpath(__file__)), "transactions", "unified")
2834

test/unified_format.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -495,6 +495,10 @@ def _create_entity(self, entity_spec, uri=None):
495495
kwargs["h"] = client_context.mongos_seeds()
496496
kwargs.update(spec.get("uriOptions", {}))
497497
server_api = spec.get("serverApi")
498+
if "waitQueueSize" in kwargs:
499+
raise unittest.SkipTest("PyMongo does not support waitQueueSize")
500+
if "waitQueueMultiple" in kwargs:
501+
raise unittest.SkipTest("PyMongo does not support waitQueueMultiple")
498502
if server_api:
499503
kwargs["server_api"] = ServerApi(
500504
server_api["version"],
@@ -1770,6 +1774,8 @@ def check_log_messages(self, operations, spec):
17701774
def format_logs(log_list):
17711775
client_to_log = defaultdict(list)
17721776
for log in log_list:
1777+
if log.module == "ocsp_support":
1778+
continue
17731779
data = json_util.loads(log.message)
17741780
client = data.pop("clientId")
17751781
client_to_log[client].append(

0 commit comments

Comments
 (0)