Tracing Celery Tasks

tracing_celery.py

from celery.task import task
import oboe
from oboeware import loader
 
# load monkey-patched instrumentation for supported modules
loader.load_inst_modules()
 
# start traces on decorated method (sampling automatically
# controlled by smart tracing as normal web requests)
oboe.config['tracing_mode'] = 'always'
 
@task
@oboe.trace('celery', kvs={'Controller': 'task', 'Action': 'add'})
def add(x, y):