def METHOD_NAME(self, inspect):
    """Task that does not exist or is finished"""
    ret = inspect.query_task('d08b257e-a7f1-4b92-9fea-be911441cb2a')
    assert len(ret) == 1
    assert ret[NODENAME] == {}
    # Task in progress
    res = sleeping.delay(5)
    sleep(1)
    ret = inspect.query_task(res.task_id)
    assert len(ret) == 1
    assert ret[NODENAME] == {
        res.task_id: [
            'active', {
                'id': res.task_id,
                'name': 't.integration.tasks.sleeping',
                'args': [5],
                'kwargs': {},
                'type': 't.integration.tasks.sleeping',
                'hostname': NODENAME,
                'time_start': ANY,
                'acknowledged': True,
                'delivery_info': {
                    'exchange': '',
                    'routing_key': 'celery',
                    'priority': 0,
                    'redelivered': False
                },
                # worker is running in the same process as separate thread
                'worker_pid': ANY
            }
        ]
    }