Skip to content
44 changes: 44 additions & 0 deletions test/asynchronous/test_command_logging.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,44 @@
# Copyright 2023-present MongoDB, Inc.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

"""Run the command monitoring unified format spec tests."""
from __future__ import annotations

import os
import pathlib
import sys

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

from test import unittest
from test.asynchronous.unified_format import generate_test_classes

_IS_SYNC = False

# Location of JSON test specifications.
if _IS_SYNC:
_TEST_PATH = os.path.join(pathlib.Path(__file__).resolve().parent, "command_logging")
else:
_TEST_PATH = os.path.join(pathlib.Path(__file__).resolve().parent.parent, "command_logging")


globals().update(
generate_test_classes(
_TEST_PATH,
module=__name__,
)
)

if __name__ == "__main__":
unittest.main()
9 changes: 8 additions & 1 deletion test/test_command_logging.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,15 +16,22 @@
from __future__ import annotations

import os
import pathlib
import sys

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

from test import unittest
from test.unified_format import generate_test_classes

_IS_SYNC = True

# Location of JSON test specifications.
_TEST_PATH = os.path.join(os.path.dirname(os.path.realpath(__file__)), "command_logging")
if _IS_SYNC:
_TEST_PATH = os.path.join(pathlib.Path(__file__).resolve().parent, "command_logging")
else:
_TEST_PATH = os.path.join(pathlib.Path(__file__).resolve().parent.parent, "command_logging")


globals().update(
generate_test_classes(
Expand Down
1 change: 1 addition & 0 deletions tools/synchro.py
Original file line number Diff line number Diff line change
Expand Up @@ -192,6 +192,7 @@ def async_only_test(f: str) -> bool:
"test_client_context.py",
"test_collation.py",
"test_collection.py",
"test_command_logging.py",
"test_common.py",
"test_connections_survive_primary_stepdown_spec.py",
"test_cursor.py",
Expand Down
Loading