task_result.py

def is_task_ready(task_id):
    async_result = AsyncResult(task_id)
    try:
        result = async_result.get(timeout=5, propagate=False)
    except TimeoutError:
        result = None
    status = async_result.status  # pylint: disable=W0621
    traceback = async_result.traceback
    if isinstance(result, Exception):
        return {
            'success': False,
            'status': status,
            'error': str(result),
            'traceback': traceback,
        }
    else:
        return {
            'success': True,
            'status': status,
            'items': result,
        }