Cleanup

dlt-hub · May 14, 2024 · cdd613b · cdd613b
1 parent 1f5ccb4
commit cdd613b
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 4 deletions.
diff --git 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
@@ -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():