Fix: block time should be second (#32)

b-scheduler · Aug 26, 2024 · 56fd527 · 56fd527
1 parent 0424b10
commit 56fd527
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/brq/consumer.py b/brq/consumer.py
@@ -275,7 +275,7 @@ async def _pool_job(self):
  consumername=self.consumer_identifier,
  streams={self.stream_name: ">"},
  count=self.count_per_fetch,
- block=self.block_time,
+ block=int(self.block_time * 1000),
  )
  if not poll_result:
  return
@@ -299,7 +299,7 @@ async def _pool_job_prallel(self):
  consumername=self.consumer_identifier,
  streams={self.stream_name: ">"},
  count=self.count_per_fetch,
- block=self.block_time,
+ block=int(self.block_time * 1000),
  )
  if not pool_result:
  return