Compatibility tests: tpch column (#16518)

Author: maximyurchuk

ydb/tests/functional/compatibility/test_stress.py

@@ -31,6 +31,10 @@ def setup(self, request):
             binary_paths=binary_paths,
             # uncomment for 64 datetime in tpc-h/tpc-ds
             # extra_feature_flags={"enable_table_datetime64": True},
+
+            column_shard_config={
+                'disabled_on_scheme_shard': False,
+            },
         )
 
         self.cluster = KiKiMR(self.config)
@@ -56,7 +60,7 @@ def get_command_prefix_log(self, subcmds: list[str], path: str) -> list[str]:
             + ["--path", path]
         )
 
-    @pytest.mark.parametrize("store_type", ["row"])
+    @pytest.mark.parametrize("store_type", ["row", "column"])
     def test_log(self, store_type):
         timeout_scale = 60
 
@@ -122,13 +126,13 @@ def test_log(self, store_type):
         select.wait()
 
     @pytest.mark.skip(reason="Too huge logs")
-    @pytest.mark.parametrize("mode", ["row"])
-    def test_simple_queue(self, mode: str):
-        with Workload(f"grpc://localhost:{self.cluster.nodes[1].grpc_port}", "/Root", 180, mode) as workload:
+    @pytest.mark.parametrize("store_type", ["row", "column"])
+    def test_simple_queue(self, store_type: str):
+        with Workload(f"grpc://localhost:{self.cluster.nodes[1].grpc_port}", "/Root", 180, store_type) as workload:
             for handle in workload.loop():
                 handle()
 
-    @pytest.mark.parametrize("store_type", ["row"])
+    @pytest.mark.parametrize("store_type", ["row", "column"])
     def test_kv(self, store_type):
         init_command_prefix = [
             yatest.common.binary_path(os.getenv("YDB_CLI_BINARY")),
@@ -198,7 +202,7 @@ def test_kv(self, store_type):
         yatest.common.execute(init_command, wait=True, stdout=self.output_f, stderr=self.output_f)
         yatest.common.execute(run_command, wait=True, stdout=self.output_f, stderr=self.output_f)
 
-    @pytest.mark.parametrize("store_type", ["row"])
+    @pytest.mark.parametrize("store_type", ["row", "column"])
     def test_tpch1(self, store_type):
         init_command = [
             yatest.common.binary_path(os.getenv("YDB_CLI_BINARY")),
@@ -253,7 +257,7 @@ def test_tpch1(self, store_type):
         yatest.common.execute(run_command, wait=True, stdout=self.output_f, stderr=self.output_f)
 
     @pytest.mark.skip(reason="Not stabilized yet")
-    @pytest.mark.parametrize("store_type", ["row"])
+    @pytest.mark.parametrize("store_type", ["row", "column"])
     def test_tpcds1(self, store_type):
         init_command = [
             yatest.common.binary_path(os.getenv("YDB_CLI_BINARY")),