diff --git a/tests/load/pipeline/test_pipelines.py b/tests/load/pipeline/test_pipelines.py
index 872ad71d16..72eb18cb79 100644
--- a/tests/load/pipeline/test_pipelines.py
+++ b/tests/load/pipeline/test_pipelines.py
@@ -1015,7 +1015,11 @@ def table_3(make_data=False):
                 ):
                     with client.with_staging_dataset():
                         tab_name = client.make_qualified_table_name(table_name)
-                        ind = tab_name.rfind(".") - 1
+                        if destination_config.destination == "clickhouse":
+                            ind = tab_name.rfind("___")
+                        else:
+                            ind = tab_name.rfind(".") - 1
+
                         tab_name = tab_name[:ind] + "_staging" + tab_name[ind:]
 
                         with client.execute_query(f"SELECT * FROM {tab_name}") as cur: