

def test_remove_images_resp(self):
    cluster_db = self.env.create()
    task = Task(name=consts.TASK_NAMES.remove_images, cluster_id=cluster_db.id)
    self.db.add(task)
    self.db.flush()
    kwargs = {
        'task_uuid': task.uuid,
        'progress': 100,
        'status': consts.TASK_STATUSES.ready,
    }
    self.receiver.remove_images_resp(**kwargs)
    self.db().refresh(task)
    self.assertEqual(consts.TASK_STATUSES.ready, task.status)

dataset/ETHPy150Open openstack/fuel-web/nailgun/nailgun/test/integration/test_rpc_consumer.py TestConsumer.test_remove_images_resp/original