(
worker: ContextPropagatingThreadPoolExecutor, messages: Message[ValuesBatch[KafkaPayload]]
)
| 105 | |
| 106 | |
| 107 | def process_batch( |
| 108 | worker: ContextPropagatingThreadPoolExecutor, messages: Message[ValuesBatch[KafkaPayload]] |
| 109 | ) -> None: |
| 110 | from sentry.issues.occurrence_consumer import process_occurrence_batch |
| 111 | |
| 112 | try: |
| 113 | process_occurrence_batch(worker, messages) |
| 114 | except Exception: |
| 115 | logger.exception("failed to process batch payload") |
nothing calls this directly
no test coverage detected