diff --git a/sink-connector/tests/integration/regression.py b/sink-connector/tests/integration/regression.py index 88b663484..0d8398348 100755 --- a/sink-connector/tests/integration/regression.py +++ b/sink-connector/tests/integration/regression.py @@ -118,13 +118,12 @@ def regression( "deduplication", "primary_keys", "virtual_columns", - "columns_inconsistency" + "columns_inconsistency", ] for module in modules: Feature(run=load(f"tests.{module}", "module")) Feature(run=load("tests.consistency", "module")) - Feature(run=load("tests.manual_section", "module")) if __name__ == "__main__": diff --git a/sink-connector/tests/integration/tests/manual_section.py b/sink-connector/tests/integration/tests/manual_section.py deleted file mode 100644 index 8ac719062..000000000 --- a/sink-connector/tests/integration/tests/manual_section.py +++ /dev/null @@ -1,83 +0,0 @@ -from integration.tests.steps.sql import * -from integration.tests.steps.statements import * -from integration.tests.steps.service_settings_steps import * - - -@TestOutline -def mysql_to_clickhouse_connection( - self, - mysql_columns, - clickhouse_table, - clickhouse_columns=None, -): - """Basic check MySQL to Clickhouse connection by small and simple data insert.""" - - table_name = f"manual_{getuid()}" - - mysql = self.context.cluster.node("mysql-master") - - init_sink_connector( - auto_create_tables=clickhouse_table[0], topics=f"SERVER5432.test.{table_name}" - ) - - with Given(f"I create MySql to CH replicated table", description=table_name): - create_mysql_to_clickhouse_replicated_table( - name=table_name, - mysql_columns=mysql_columns, - clickhouse_columns=clickhouse_columns, - clickhouse_table=clickhouse_table, - ) - - with When(f"I insert data in MySql table"): - complex_insert( - node=mysql, - table_name=table_name, - values=["({x},{y})", "({x},{y})"], - partitions=1, - parts_per_partition=1, - block_size=10, - ) - - with Then( - "I check that MySQL tables and Clickhouse replication tables have the same data" - ): - complex_check_creation_and_select( - table_name=table_name, - clickhouse_table=clickhouse_table, - statement="count(*)", - with_final=True, - ) - - -@TestFeature -@Name("mysql to clickhouse") -def mysql_to_clickhouse( - self, - mysql_columns="MyData INT", - clickhouse_columns="MyData Int32", -): - """Just imitation of tests.""" - for clickhouse_table in available_clickhouse_tables: - if clickhouse_table[0] == "auto": - with Example({clickhouse_table}, flags=TE): - mysql_to_clickhouse_connection( - mysql_columns=mysql_columns, - clickhouse_columns=clickhouse_columns, - clickhouse_table=clickhouse_table, - ) - - -@TestModule -@Name("manual section") -def module(self): - """MySql to ClickHouse replication manual checks section.""" - - with Given("I enable debezium connector after kafka starts up"): - init_debezium_connector() - - with Pool(1) as executor: - try: - for feature in loads(current_module(), Feature): - Feature(test=feature, parallel=True, executor=executor)() - finally: - join()