#NEWLINE# @ signals . after_task_publish . connect #NEWLINE# def on_task_sent( sender = None , body = None , **kwargs ) : #NEWLINE# #INDENT# with blueox . Context ( '.celery.task_sent' ) : #NEWLINE# #INDENT# blueox . set ( 'task_id' , body [ 'id' ] ) #NEWLINE# blueox . set ( 'task' , str ( body [ 'task' ] ) ) #NEWLINE# blueox . set ( 'eta' , body [ 'eta' ] )