More issues around paused polling #458
Description
MessageRejected: null
File "arroyo/processing/processor.py", line 429, in _run_once
self.__processing_strategy.submit(message)
File "sentry/sentry_metrics/consumers/indexer/common.py", line 108, in submit
raise MessageRejected
AssertionError: null
File "<frozen runpy>", line 198, in _run_module_as_main
File "<frozen runpy>", line 88, in _run_code
File "__main__.py", line 4, in <module>
main()
File "sentry/runner/main.py", line 145, in main
func(**kwargs)
File "click/core.py", line 1157, in __call__
return self.main(*args, **kwargs)
File "click/core.py", line 1078, in main
rv = self.invoke(ctx)
File "click/core.py", line 1688, in invoke
return _process_result(sub_ctx.command.invoke(sub_ctx))
File "click/core.py", line 1688, in invoke
return _process_result(sub_ctx.command.invoke(sub_ctx))
File "click/core.py", line 1434, in invoke
return ctx.invoke(self.callback, **ctx.params)
File "click/core.py", line 783, in invoke
return __callback(*args, **kwargs)
File "click/decorators.py", line 33, in new_func
return f(get_current_context(), *args, **kwargs)
File "sentry/runner/decorators.py", line 82, in inner
return ctx.invoke(f, *args, **kwargs)
File "click/core.py", line 783, in invoke
return __callback(*args, **kwargs)
File "click/decorators.py", line 33, in new_func
return f(get_current_context(), *args, **kwargs)
File "sentry/runner/decorators.py", line 34, in inner
return ctx.invoke(f, *args, **kwargs)
File "click/core.py", line 783, in invoke
return __callback(*args, **kwargs)
File "sentry/runner/commands/run.py", line 612, in basic_consumer
run_processor_with_signals(processor, quantized_rebalance_delay_secs)
File "sentry/utils/kafka.py", line 47, in run_processor_with_signals
processor.run()
File "arroyo/processing/processor.py", line 334, in run
self._run_once()
File "arroyo/processing/processor.py", line 477, in _run_once
assert self.__consumer.poll(0.1) is None
arroyo version: 2.21.0