getsentry / arroyo

A library to build streaming applications that consume from and produce to Kafka.
https://getsentry.github.io/arroyo/
Apache License 2.0
41 stars 7 forks source link

metric(multiprocessing): Add metric to track time it takes to prepare and submit batch #352

Open ayirr7 opened 5 months ago

ayirr7 commented 5 months ago

Need to fix the tests since the test_run_task_with_multiprocessing asserts against all metrics calls.