ddtrace/contrib/celery/utils.py
def retrieve_span(task, task_id):
    """Helper to retrieve an active `Span` stored in a `Task`
    instance
    """
    weak_dict = getattr(task, CTX_KEY, None)
    if weak_dict is None:
        return
    else:
        return weak_dict.get(task_id)
Helper to retrieve an active `Span` stored in a `Task`
    instance
    
Helper to retrieve an active `Span` stored in a `Task`
instance
Helper to retrieve an active ` Span ` stored in a ` Task ` instance
def retrieve_span(task, task_id):
    weak_dict = getattr(task, CTX_KEY, None)
    if weak_dict is None:
        return
    else:
        return weak_dict.get(task_id)
def retrieve_span ( task , task_id ) : weak_dict = getattr ( task , CTX_KEY , None ) if weak_dict is None : return else : return weak_dict . get ( task_id )
Helper to retrieve an active `Span` stored in a `Task`
instance
Helper to retrieve an active ` Span ` stored in a ` Task ` instance
"""Helper to retrieve an active `Span` stored in a `Task`
    instance
    """
task
task_id