FIX: Use redis BLMOVE instead of BRPOPLPUSH (deprecated)

Fixes #1827 Signed-off-by: Sebastian Waldbauer <[email protected]>
certtools · Feb 3, 2022 · 54305be · 54305be
1 parent 8d1c926
commit 54305be
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/intelmq/lib/pipeline.py b/intelmq/lib/pipeline.py
@@ -261,8 +261,7 @@ def _receive(self) -> bytes:
  else:
  break
  if not retval:
- retval = self.pipe.brpoplpush(self.source_queue,
- self.internal_queue, 0)
+ retval = self.pipe.blmove(self.source_queue, self.internal_queue, 0, 'RIGHT', 'LEFT')
  except Exception as exc:
  raise exceptions.PipelineError(exc)
  else: