Rename a function

dlt-hub · Feb 5, 2024 · 320bdc9 · 320bdc9
1 parent 3483144
commit 320bdc9
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/sources/scraping/helpers.py b/sources/scraping/helpers.py
@@ -16,7 +16,7 @@
 
 from .types import AnyDict
 from .queue import BaseQueue
-from .scrapy.pipeline_item import get_pipeline_item
+from .scrapy.pipeline_item import get_item_pipeline
 from .settings import SOURCE_SCRAPY_SETTINGS, SOURCE_SCRAPY_QUEUE_SIZE
 
 
@@ -124,7 +124,7 @@ def create_pipeline_runner(
     if queue is None:
         queue = BaseQueue(maxsize=queue_size)
 
-    scrapy_pipeline_item = get_pipeline_item(queue)
+    scrapy_pipeline_item = get_item_pipeline(queue)
     settings = {
         "ITEM_PIPELINES": {scrapy_pipeline_item: 100},
         **SOURCE_SCRAPY_SETTINGS,

diff --git a/sources/scraping/scrapy/pipeline_item.py b/sources/scraping/scrapy/pipeline_item.py
@@ -16,7 +16,7 @@ def process_item(
         raise NotImplementedError
 
 
-def get_pipeline_item(queue: Type[BaseQueue]) -> Type[PipelineItem]:
+def get_item_pipeline(queue: Type[BaseQueue]) -> Type[PipelineItem]:
     """Wraps our custom ItemPipeline and provides queue instance
 
     It is done this way because there is no way to define