Class Context

celery/app/task.py:71–179

Task request variables (Task.request).

class Context:
    """Task request variables (Task.request)."""

    _children = None   # see property
    _protected = 0
    args = None
    callbacks = None
    called_directly = True
    chain = None
    chord = None
    correlation_id = None
    delivery_info = None
    errbacks = None
    eta = None
    expires = None
    group = None
    group_index = None
    headers = None
    hostname = None
    id = None
    ignore_result = False
    is_eager = False
    kwargs = None
    logfile = None
    loglevel = None
    origin = None
    parent_id = None
    properties = None
    retries = 0
    reply_to = None
    replaced_task_nesting = 0
    root_id = None
    shadow = None
    taskset = None   # compat alias to group
    timelimit = None
    utc = None
    stamped_headers = None
    stamps = None

    def __init__(self, *args, **kwargs):
        self.update(*args, **kwargs)
        if self.headers is None:
            self.headers = self._get_custom_headers(*args, **kwargs)

    def _get_custom_headers(self, *args, **kwargs):
        headers = {}
        headers.update(*args, **kwargs)
        celery_keys = {*Context.__dict__.keys(), 'lang', 'task', 'argsrepr', 'kwargsrepr', 'compression'}
        for key in celery_keys:
            headers.pop(key, None)
        if not headers:
            return None
        return headers

    def update(self, *args, **kwargs):
        return self.__dict__.update(*args, **kwargs)

    def clear(self):