Skip to content

More issues around paused polling #458

Description

@untitaker
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

https://sentry-st.sentry.io/issues/6578853096/?alert_rule_id=14689092&alert_type=issue&notification_uuid=5596a59d-2264-46d6-8aca-735bef64f485&project=6165734&referrer=slack

arroyo version: 2.21.0

Activity

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

      Milestone

      No milestone

      Relationships

      None yet

      Development

      No branches or pull requests

      Issue actions