From 7bb64c80b9c01b3cc629bf4dd01e0fe9939f61f5 Mon Sep 17 00:00:00 2001 From: Steinthor Palsson Date: Sat, 11 May 2024 14:00:44 -0400 Subject: [PATCH] Cleanup --- dlt/load/load.py | 4 +--- dlt/pipeline/pipeline.py | 1 - 2 files changed, 1 insertion(+), 4 deletions(-) diff --git a/dlt/load/load.py b/dlt/load/load.py index 892a4c4b9c..5349eeb197 100644 --- a/dlt/load/load.py +++ b/dlt/load/load.py @@ -11,7 +11,7 @@ from dlt.common.configuration import with_config, known_sections from dlt.common.configuration.resolve import inject_section from dlt.common.configuration.accessors import config -from dlt.common.pipeline import LoadInfo, LoadMetrics, SupportsPipeline, WithStepInfo, TRefreshMode +from dlt.common.pipeline import LoadInfo, LoadMetrics, SupportsPipeline, WithStepInfo from dlt.common.schema.utils import get_top_level_table from dlt.common.schema.typing import TTableSchema from dlt.common.storages.load_storage import LoadPackageInfo, ParsedLoadJobFileName, TJobState @@ -69,7 +69,6 @@ def __init__( config: LoaderConfiguration = config.value, initial_client_config: DestinationClientConfiguration = config.value, initial_staging_client_config: DestinationClientConfiguration = config.value, - refresh: Optional[TRefreshMode] = None, ) -> None: self.config = config self.collector = collector @@ -81,7 +80,6 @@ def __init__( self.pool = NullExecutor() self.load_storage: LoadStorage = self.create_storage(is_storage_owner) self._loaded_packages: List[LoadPackageInfo] = [] - self.refresh = refresh super().__init__() def create_storage(self, is_storage_owner: bool) -> LoadStorage: diff --git a/dlt/pipeline/pipeline.py b/dlt/pipeline/pipeline.py index 58e30fbdf6..5279b5cfe9 100644 --- a/dlt/pipeline/pipeline.py +++ b/dlt/pipeline/pipeline.py @@ -562,7 +562,6 @@ def load( config=load_config, initial_client_config=client.config, initial_staging_client_config=staging_client.config if staging_client else None, - refresh=self.refresh if not self.first_run else None, ) try: with signals.delayed_signals():