From 73b79ee02073b89bcf3a90cb2fe0e54ed8f1cd9a Mon Sep 17 00:00:00 2001 From: Marcin Rudolf Date: Thu, 14 Nov 2024 22:02:44 +0100 Subject: [PATCH] fixes clickhouse adapter test --- tests/load/clickhouse/test_clickhouse_adapter.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/tests/load/clickhouse/test_clickhouse_adapter.py b/tests/load/clickhouse/test_clickhouse_adapter.py index e8e2b327c0..f36df0ee3f 100644 --- a/tests/load/clickhouse/test_clickhouse_adapter.py +++ b/tests/load/clickhouse/test_clickhouse_adapter.py @@ -1,7 +1,6 @@ from typing import Generator, Dict, cast import dlt -from dlt.common.utils import custom_environ from dlt.destinations.adapters import clickhouse_adapter from dlt.destinations.impl.clickhouse.sql_client import ClickHouseSqlClient from dlt.destinations.impl.clickhouse.typing import TDeployment @@ -34,7 +33,12 @@ def not_annotated_resource() -> Generator[Dict[str, int], None, None]: clickhouse_adapter(merge_tree_resource, table_engine_type="merge_tree") clickhouse_adapter(replicated_merge_tree_resource, table_engine_type="replicated_merge_tree") - pipe = dlt.pipeline(pipeline_name="adapter_test", destination="clickhouse", dev_mode=True) + pipe = dlt.pipeline( + pipeline_name="adapter_test", + destination="clickhouse", + dev_mode=True, + dataset_name="adapter_test_ds", + ) with pipe.sql_client() as client: deployment_type: TDeployment = get_deployment_type(cast(ClickHouseSqlClient, client))