From 33ebcaeda0fb5514a12f076da73d5e7a6f5895f9 Mon Sep 17 00:00:00 2001
From: Jorrit Schaap <schaap@astron.nl>
Date: Thu, 12 Nov 2020 11:49:24 +0100
Subject: [PATCH] TMSS-190: no need (at this moment) to startup RADBPGListener.
Saves startup time.
---
.../ResourceAssigner/test/ra_test_environment.py | 7 -------
1 file changed, 7 deletions(-)
diff --git a/SAS/ResourceAssignment/ResourceAssigner/test/ra_test_environment.py b/SAS/ResourceAssignment/ResourceAssigner/test/ra_test_environment.py
index 7889f0153a1..5046b4eb97f 100644
--- a/SAS/ResourceAssignment/ResourceAssigner/test/ra_test_environment.py
+++ b/SAS/ResourceAssignment/ResourceAssigner/test/ra_test_environment.py
@@ -34,7 +34,6 @@ from lofar.sas.resourceassignment.database.testing.radb_common_testing import RA
from lofar.sas.resourceassignment.resourceassigner.raservice import RAService
from lofar.sas.resourceassignment.resourceassignmentservice.service import createService as createRADBService
from lofar.sas.resourceassignment.resourceassignmentestimator.service import createService as createEstimatorService
-from lofar.sas.resourceassignment.database.radbpglistener import RADBPGListener
class RATestEnvironment:
'''Create and run a several ResourrceAssigner services in an isolated test environment'''
@@ -45,21 +44,15 @@ class RATestEnvironment:
self.radb_service = createRADBService(dbcreds=self.radb_test_instance.dbcreds, exchange=exchange, broker=broker)
self.re_service = createEstimatorService(exchange=exchange, broker=broker)
self.ra_service = RAService(radbcreds=self.radb_test_instance.dbcreds, exchange=exchange, broker=broker)
- self.radb_pg_listener = None
def start(self):
self.radb_test_instance.create()
self.radb.connect()
- self.radb_pg_listener = RADBPGListener(dbcreds=self.radb_test_instance.dbcreds,
- exchange=self.radb_service.exchange,
- broker=self.radb_service.broker)
- self.radb_pg_listener.start()
self.radb_service.start_listening()
self.re_service.start_listening()
self.ra_service.start_listening()
def stop(self):
- self.radb_pg_listener.stop()
self.radb.disconnect()
self.ra_service.stop_listening()
self.re_service.stop_listening()
--
GitLab