def defer_to_events_queue(fn, *args, **kwargs):
    # See https://developers.google.com/appengine/articles/deferred for
    # details on the _queue kwarg.
    deferred.defer(fn, *args, _queue=QUEUE_NAME_EVENTS, **kwargs)


# A special exception that ensures that the task is not tried again, if it
# fails.
Add the specified filter to this handler.
dataset/ETHPy150Open oppia/oppia/core/platform/taskqueue/gae_taskqueue_services.py/defer_to_events_queue--crossover with--dataset/ETHPy150Open deanhiller/databus/webapp/play1.3.x/python/Lib/logging/__init__.py/Filterer.addFilter