

def test_provision_resp_success_notification(self):
    task = self._prepare_task(consts.TASK_NAMES.provision)
    kwargs = self._create_resp_kwargs(task.uuid, consts.TASK_STATUSES.ready, 100, consts.TASK_STATUSES.ready, 100)
    self.receiver.provision_resp(**kwargs)
    notifications_number = self.db.query(Notification).filter_by(cluster_id=task.cluster_id).count()
    self.assertEqual(1, notifications_number)

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