title: KeyError: 1 sentry snuba subscription consumer events
body: <p>I am getting an error after increasing the partition count from 1 to 2 for the snuba-commit-log topic. I sometimes saw timeout errors and thought I could fix them by increasing the partition count.
  Sentry Version: <code>22.6.0</code></p>
  <pre><code>   return _process_result(sub_ctx.command.invoke(sub_ctx))
   File &quot;/usr/local/lib/python3.8/site-packages/click/core.py&quot;, line 1404, in invoke
     return ctx.invoke(self.callback, **ctx.params)
   File &quot;/usr/local/lib/python3.8/site-packages/click/core.py&quot;, line 760, in invoke
     return __callback(*args, **kwargs)
   File &quot;/usr/src/snuba/snuba/cli/subscriptions_scheduler_executor.py&quot;, line 162, in subscriptions_scheduler_executor
     processor.run()
   File &quot;/usr/local/lib/python3.8/site-packages/arroyo/processing/processor.py&quot;, line 131, in run
     self._run_once()
   File &quot;/usr/local/lib/python3.8/site-packages/arroyo/processing/processor.py&quot;, line 169, in _run_once
     self.__processing_strategy.submit(self.__message)
   File &quot;/usr/src/snuba/snuba/subscriptions/scheduler_processing_strategy.py&quot;, line 252, in submit
     self.__next_step.submit(message)
   File &quot;/usr/src/snuba/snuba/subscriptions/combined_scheduler_executor.py&quot;, line 256, in submit
     tasks.extend([task for task in entity_scheduler[tick.partition].find(tick)])
  KeyError: 1
  </code></pre>
  <p>I couldn't open any kind of tickets in sentry's own forum because the site seems read-only mode. That's why I preferred to ask here. Sorry if the location is not correct.</p>