@instrumented_task(name='sentry.tasks.process_buffer.process_pending')
def process_pending():
 from sentry import app
 lock = app.locks.get('buffer:process_pending', duration=60)
 try:
  with lock.acquire():
   app.buffer.process_pending()
 except UnableToAcquireLock as error:
  logger.warning('process_pending.fail', extra={'error': error})

@ instrumented_task ( name = 'sentry.tasks.process_buffer.process_pending' ) def process_pending ( ) : from sentry import app lock = app . locks . get ( 'buffer:process_pending' , duration = 60 ) try : with lock . acquire ( ) : app . buffer . process_pending ( ) except UnableToAcquireLock as error : logger . warning ( 'process_pending.fail' , extra = { 'error' : error } )
process pending buffers .