Skip to content

Commit fbae227

Browse files
committed
PYTHON-2453 Fix various test failures with requireApiVersion=1
1 parent 30a43fe commit fbae227

File tree

3 files changed

+6
-3
lines changed

3 files changed

+6
-3
lines changed

test/__init__.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -758,6 +758,8 @@ def sanitize_cmd(cmd):
758758
cp.pop('$db', None)
759759
cp.pop('$readPreference', None)
760760
cp.pop('lsid', None)
761+
# Versioned api parameters
762+
cp.pop('apiVersion', None)
761763
# OP_MSG encoding may move the payload type one field to the
762764
# end of the command. Do the same here.
763765
name = next(iter(cp))

test/test_pooling.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -176,6 +176,7 @@ def create_pool(
176176
pool_options = client_context.client._topology_settings.pool_options
177177
kwargs['ssl_context'] = pool_options.ssl_context
178178
kwargs['ssl_match_hostname'] = pool_options.ssl_match_hostname
179+
kwargs['server_api'] = pool_options.server_api
179180
return Pool(pair, PoolOptions(*args, **kwargs))
180181

181182

test/test_versioned_api.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@
2222

2323
from test import client_context, IntegrationTest, unittest
2424
from test.unified_format import generate_test_classes
25-
from test.utils import EventListener, rs_or_single_client
25+
from test.utils import OvertCommandListener, rs_or_single_client
2626

2727

2828
TEST_PATH = os.path.join(
@@ -74,7 +74,7 @@ def assertServerApiOnlyInFirstCommand(self, events):
7474
self.assertNoServerApi(event)
7575

7676
def test_command_options(self):
77-
listener = EventListener()
77+
listener = OvertCommandListener()
7878
client = rs_or_single_client(server_api=ServerApi('1'),
7979
event_listeners=[listener])
8080
self.addCleanup(client.close)
@@ -91,7 +91,7 @@ def test_command_options(self):
9191

9292
@client_context.require_transactions
9393
def test_command_options_txn(self):
94-
listener = EventListener()
94+
listener = OvertCommandListener()
9595
client = rs_or_single_client(server_api=ServerApi('1'),
9696
event_listeners=[listener])
9797
self.addCleanup(client.close)

0 commit comments

Comments
 (0)