sync

Author: rekby

tests/conftest.py

@@ -4,6 +4,7 @@
 import pytest
 import ydb
 import time
+import subprocess
 
 
 @pytest.fixture(autouse=True, scope="session")
@@ -56,9 +57,9 @@ def secure_endpoint(pytestconfig, session_scoped_container_getter):
     assert os.path.exists(ca_path)
     os.environ["YDB_SSL_ROOT_CERTIFICATES_FILE"] = ca_path
     with ydb.Driver(
-        endpoint="grpcs://localhost:2135",
-        database="/local",
-        root_certificates=ydb.load_ydb_root_certificate(),
+            endpoint="grpcs://localhost:2135",
+            database="/local",
+            root_certificates=ydb.load_ydb_root_certificate(),
     ) as driver:
         wait_container_ready(driver)
     yield "localhost:2135"
@@ -96,3 +97,18 @@ async def driver(endpoint, database, event_loop):
     yield driver
 
     await driver.stop(timeout=10)
+
+
+@pytest.fixture()
+def topic_path() -> str:
+    subprocess.run(
+        """docker-compose exec ydb /ydb -e grpc://localhost:2136 -d /local topic drop /local/test-topic""",
+        shell=True,
+    )
+    res = subprocess.run(
+        """exec ydb /ydb -e grpc://localhost:2136 -d /local topic create /local/test-topic""",
+        shell=True,
+    )
+    assert res.returncode == 0
+
+    return "/local/test-topic"

tests/topics/test_topic_writer_async.py

@@ -0,0 +1,4 @@
+
+
+def test_write_single_message(driver, topic_path):
+    print(topic_path)