Skip to content

Commit 81e1d55

Browse files
committed
fix usage of parse_client_options
1 parent 68c2a07 commit 81e1d55

File tree

2 files changed

+10
-2
lines changed

2 files changed

+10
-2
lines changed

test/asynchronous/utils_spec_runner.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -595,6 +595,10 @@ async def run_test_ops(self, sessions, collection, test):
595595
"""
596596
await self.run_operations(sessions, collection, test["operations"])
597597

598+
def parse_client_options(self, opts):
599+
"""Allow encryption spec to override a clientOptions parsing."""
600+
return opts
601+
598602
async def setup_scenario(self, scenario_def):
599603
"""Allow specs to override a test's setup."""
600604
db_name = self.get_scenario_db_name(scenario_def)
@@ -641,7 +645,7 @@ async def run_scenario(self, scenario_def, test):
641645
pool_listener = CMAPListener()
642646
server_listener = ServerAndTopologyEventListener()
643647
# Create a new client, to avoid interference from pooled sessions.
644-
client_options = test["clientOptions"]
648+
client_options = self.parse_client_options(test["clientOptions"])
645649
use_multi_mongos = test["useMultipleMongoses"]
646650
host = None
647651
if use_multi_mongos:

test/utils_spec_runner.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -595,6 +595,10 @@ def run_test_ops(self, sessions, collection, test):
595595
"""
596596
self.run_operations(sessions, collection, test["operations"])
597597

598+
def parse_client_options(self, opts):
599+
"""Allow encryption spec to override a clientOptions parsing."""
600+
return opts
601+
598602
def setup_scenario(self, scenario_def):
599603
"""Allow specs to override a test's setup."""
600604
db_name = self.get_scenario_db_name(scenario_def)
@@ -641,7 +645,7 @@ def run_scenario(self, scenario_def, test):
641645
pool_listener = CMAPListener()
642646
server_listener = ServerAndTopologyEventListener()
643647
# Create a new client, to avoid interference from pooled sessions.
644-
client_options = test["clientOptions"]
648+
client_options = self.parse_client_options(test["clientOptions"])
645649
use_multi_mongos = test["useMultipleMongoses"]
646650
host = None
647651
if use_multi_mongos:

0 commit comments

Comments
 (0)