fixed typo

dmitry-sles-novikov · dmitry-sles-novikov · commit bdae3a37db61 · 2025-08-29T12:43:01.000+03:00
diff --git a/tests/integration/test_storage_nats/test_nats_core.py b/tests/integration/test_storage_nats/test_nats_core.py
@@ -121,7 +121,7 @@ def test_nats_select(nats_cluster):
     messages = []
     for i in range(50):
         messages.append(json.dumps({"key": i, "value": i}))
-    asyncio.run(publich_messages(nats_cluster, "select", messages))
+    asyncio.run(publish_messages(nats_cluster, "select", messages))
 
     nats_helpers.check_query_result(instance, "SELECT * FROM test.view ORDER BY key")
 
@@ -154,13 +154,13 @@ def test_nats_json_without_delimiter(nats_cluster):
         messages += json.dumps({"key": i, "value": i}) + "\n"
 
     all_messages = [messages]
-    asyncio.run(publich_messages(nats_cluster, "json", all_messages))
+    asyncio.run(publish_messages(nats_cluster, "json", all_messages))
 
     messages = ""
     for i in range(25, 50):
         messages += json.dumps({"key": i, "value": i}) + "\n"
     all_messages = [messages]
-    asyncio.run(publich_messages(nats_cluster, "json", all_messages))
+    asyncio.run(publish_messages(nats_cluster, "json", all_messages))
 
     nats_helpers.check_query_result(instance, "SELECT * FROM test.view ORDER BY key")
 
@@ -193,7 +193,7 @@ def test_nats_csv_with_delimiter(nats_cluster):
     for i in range(50):
         messages.append("{i}, {i}".format(i=i))
 
-    asyncio.run(publich_messages(nats_cluster, "csv", messages))
+    asyncio.run(publish_messages(nats_cluster, "csv", messages))
     time.sleep(1)
 
     nats_helpers.check_query_result(instance, "SELECT * FROM test.view ORDER BY key")
@@ -227,7 +227,7 @@ def test_nats_tsv_with_delimiter(nats_cluster):
     for i in range(50):
         messages.append("{i}\t{i}".format(i=i))
 
-    asyncio.run(publich_messages(nats_cluster, "tsv", messages))
+    asyncio.run(publish_messages(nats_cluster, "tsv", messages))
 
     nats_helpers.check_query_result(instance, "SELECT * FROM test.view ORDER BY key")
 
@@ -260,7 +260,7 @@ def test_nats_macros(nats_cluster):
     message = ""
     for i in range(50):
         message += json.dumps({"key": i, "value": i}) + "\n"
-    asyncio.run(publich_messages(nats_cluster, "test_subject", [message]))
+    asyncio.run(publish_messages(nats_cluster, "test_subject", [message]))
 
     nats_helpers.check_query_result(instance, "SELECT * FROM test.view ORDER BY key")
 
@@ -297,7 +297,7 @@ def test_nats_materialized_view(nats_cluster):
     messages = []
     for i in range(50):
         messages.append(json.dumps({"key": i, "value": i}))
-    asyncio.run(publich_messages(nats_cluster, "mv", messages))
+    asyncio.run(publish_messages(nats_cluster, "mv", messages))
 
     nats_helpers.check_query_result(instance, "SELECT * FROM test.view1 ORDER BY key")
     nats_helpers.check_query_result(instance, "SELECT * FROM test.view2 ORDER BY key")
@@ -330,7 +330,7 @@ def test_nats_materialized_view_with_subquery(nats_cluster):
     messages = []
     for i in range(50):
         messages.append(json.dumps({"key": i, "value": i}))
-    asyncio.run(publich_messages(nats_cluster, "mvsq", messages))
+    asyncio.run(publish_messages(nats_cluster, "mvsq", messages))
 
     nats_helpers.check_query_result(instance, "SELECT * FROM test.view ORDER BY key")
 
@@ -367,7 +367,7 @@ def produce_messages(range):
             msg.value = str(i)
             serialized_msg = msg.SerializeToString()
             data = data + _VarintBytes(len(serialized_msg)) + serialized_msg
-        asyncio.run(publich_messages(nats_cluster, "pb", bytes=data))
+        asyncio.run(publish_messages(nats_cluster, "pb", bytes=data))
     
     produce_messages(range(0, 20))
     produce_messages(range(20, 21))
@@ -407,7 +407,7 @@ def test_nats_big_message(nats_cluster):
     )
     nats_helpers.wait_for_mv_attached_to_table(instance, "test.nats")
 
-    asyncio.run(publich_messages(nats_cluster, "big", messages))
+    asyncio.run(publish_messages(nats_cluster, "big", messages))
 
     result = instance.query_with_retry(
         "SELECT count() FROM test.view",
@@ -461,7 +461,7 @@ def produce():
         for _ in range(messages_num):
             messages.append(json.dumps({"key": i[0], "value": i[0]}))
             i[0] += 1
-        asyncio.run(publich_messages(nats_cluster, "combo", messages))
+        asyncio.run(publish_messages(nats_cluster, "combo", messages))
 
     threads = []
     threads_num = 20
@@ -837,7 +837,7 @@ def test_nats_virtual_column(nats_cluster):
         messages.append(json.dumps({"key": i, "value": i}))
         i += 1
 
-    asyncio.run(publich_messages(nats_cluster, "virtuals", messages))
+    asyncio.run(publish_messages(nats_cluster, "virtuals", messages))
 
     result = instance.query_with_retry("SELECT count() FROM test.view", check_callback = lambda num_rows: int(num_rows) == message_num)
     assert int(result) == message_num
@@ -895,7 +895,7 @@ def test_nats_virtual_column_with_materialized_view(nats_cluster):
         messages.append(json.dumps({"key": i, "value": i}))
         i += 1
 
-    asyncio.run(publich_messages(nats_cluster, "virtuals_mv", messages))
+    asyncio.run(publish_messages(nats_cluster, "virtuals_mv", messages))
 
     result = instance.query_with_retry("SELECT count() FROM test.view", check_callback = lambda num_rows: int(num_rows) == message_num)
     assert int(result) == message_num
@@ -965,7 +965,7 @@ def produce():
         for _ in range(messages_num):
             messages.append(json.dumps({"key": i[0], "value": i[0]}))
             i[0] += 1
-        asyncio.run(publich_messages(nats_cluster, "many_consumers", messages))
+        asyncio.run(publish_messages(nats_cluster, "many_consumers", messages))
 
     threads = []
     threads_num = 20
@@ -1099,7 +1099,7 @@ def test_nats_no_connection_at_startup_2(nats_cluster):
     messages = []
     for i in range(messages_num):
         messages.append(json.dumps({"key": i, "value": i}))
-    asyncio.run(publich_messages(nats_cluster, "cs", messages))
+    asyncio.run(publish_messages(nats_cluster, "cs", messages))
 
     result = instance.query_with_retry(
         "SELECT count() FROM test.view", 
@@ -1142,7 +1142,7 @@ def test_nats_format_factory_settings(nats_cluster):
         """SELECT parseDateTimeBestEffort(CAST('2021-01-19T14:42:33.1829214Z', 'String'))"""
     )
 
-    asyncio.run(publich_messages(nats_cluster, "format_settings", [message]))
+    asyncio.run(publish_messages(nats_cluster, "format_settings", [message]))
     result = instance.query_with_retry("SELECT date FROM test.view", check_callback = lambda query_result: query_result == expected)
 
     assert result == expected
@@ -1188,7 +1188,7 @@ def test_nats_drop_mv(nats_cluster):
     messages = []
     for i in range(20):
         messages.append(json.dumps({"key": i, "value": i}))
-    asyncio.run(publich_messages(nats_cluster, "mv", messages))
+    asyncio.run(publish_messages(nats_cluster, "mv", messages))
 
     nats_helpers.wait_query_result(instance, "SELECT count() FROM test.view", 20)
 
@@ -1198,7 +1198,7 @@ def test_nats_drop_mv(nats_cluster):
     messages = []
     for i in range(100, 200):
         messages.append(json.dumps({"key": i, "value": i}))
-    asyncio.run(publich_messages(nats_cluster, "mv", messages))
+    asyncio.run(publish_messages(nats_cluster, "mv", messages))
 
     time.sleep (1)
 
@@ -1213,7 +1213,7 @@ def test_nats_drop_mv(nats_cluster):
     messages = []
     for i in range(20, 40):
         messages.append(json.dumps({"key": i, "value": i}))
-    asyncio.run(publich_messages(nats_cluster, "mv", messages))
+    asyncio.run(publish_messages(nats_cluster, "mv", messages))
 
     nats_helpers.wait_query_result(instance, "SELECT count() FROM test.view", 40)
 
@@ -1223,7 +1223,7 @@ def test_nats_drop_mv(nats_cluster):
     messages = []
     for i in range(200, 400):
         messages.append(json.dumps({"key": i, "value": i}))
-    asyncio.run(publich_messages(nats_cluster, "mv", messages))
+    asyncio.run(publish_messages(nats_cluster, "mv", messages))
 
     time.sleep (1)
 
@@ -1238,7 +1238,7 @@ def test_nats_drop_mv(nats_cluster):
     messages = []
     for i in range(40, 50):
         messages.append(json.dumps({"key": i, "value": i}))
-    asyncio.run(publich_messages(nats_cluster, "mv", messages))
+    asyncio.run(publish_messages(nats_cluster, "mv", messages))
     nats_helpers.check_query_result(instance, "SELECT * FROM test.view ORDER BY key")
 
     instance.query("DROP VIEW test.consumer")
@@ -1247,7 +1247,7 @@ def test_nats_drop_mv(nats_cluster):
     messages = []
     for i in range(400, 500):
         messages.append(json.dumps({"key": i, "value": i}))
-    asyncio.run(publich_messages(nats_cluster, "mv", messages))
+    asyncio.run(publish_messages(nats_cluster, "mv", messages))
     nats_helpers.check_query_result(instance, "SELECT * FROM test.view ORDER BY key")
 
 
@@ -1272,7 +1272,7 @@ def test_nats_predefined_configuration(nats_cluster):
     nats_helpers.wait_for_mv_attached_to_table(instance, "test.nats")
 
     asyncio.run(
-        publich_messages(
+        publish_messages(
             nats_cluster, "named", [json.dumps({"key": 1, "value": 2})]
         )
     )
