#539 related: fixed exception caused by calling an apply_core Pipel…

…ineItemCode.
nicolay-r · Jan 2, 2024 · 2ab59da · 2ab59da
1 parent 48a0268
commit 2ab59da
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/arekit/common/pipeline/items/base.py b/arekit/common/pipeline/items/base.py
@@ -39,7 +39,8 @@ def get_source(self, src_ctx, call_func=True, force_key=None):
  return src_data
 
  def apply_core(self, input_data, pipeline_ctx):
- raise NotImplementedError()
+ """By default we do nothing."""
+ pass
 
  def apply(self, input_data, pipeline_ctx=None):
  """ Performs input processing an update it for a further pipeline items.

diff --git a/arekit/contrib/utils/pipelines/items/text/terms_splitter.py b/arekit/contrib/utils/pipelines/items/text/terms_splitter.py
@@ -5,7 +5,6 @@
 
 class TermsSplitterParser(BasePipelineItem):
 
- def apply_core(self, input_data, pipeline_ctx, **kwargs):
+ def apply_core(self, input_data, pipeline_ctx):
  assert(isinstance(pipeline_ctx, PipelineContext))
- super(TermsSplitterParser, self).apply_core(**kwargs)
  return split_by_whitespaces(input_data)