@instrumented_task(name='sentry.tasks.process_buffer.process_incr')
def process_incr(**kwargs):
 from sentry import app
 app.buffer.process(**kwargs)

@ instrumented_task ( name = 'sentry.tasks.process_buffer.process_incr' ) def process_incr ( ** kwargs ) : from sentry import app app . buffer . process ( ** kwargs )
processes a buffer event .