Skip to content
Snippets Groups Projects
Commit 58a06f56 authored by Jorrit Schaap's avatar Jorrit Schaap
Browse files

Task #8887: removed obsolete config imports

parent 4fbf72c5
No related branches found
No related tags found
No related merge requests found
......@@ -4,9 +4,3 @@
#DEFAULT_BUSNAME = 'lofar.ra.command'
#DEFAULT_SERVICENAME = 'RAtoORTBTaskSpecificationPropagationService'
try:
from lofar.sas.resourceassignment.resourceassigner.config import RA_NOTIFICATION_BUSNAME
from lofar.sas.resourceassignment.resourceassigner.config import RA_NOTIFICATION_SUBJECTS
except ImportError:
RA_NOTIFICATION_BUSNAME='lofar.ra.notification'
RA_NOTIFICATION_SUBJECTS='RA.*'
......@@ -38,7 +38,6 @@ import lofar.sas.resourceassignment.resourceassignmentservice.rpc as rarpc ## RA
from lofar.sas.resourceassignment.database.radbbuslistener import RADBBusListener
from lofar.sas.resourceassignment.database.config import DEFAULT_NOTIFICATION_BUSNAME as RA_NOTIFICATION_BUSNAME
from lofar.sas.resourceassignment.database.config import DEFAULT_NOTIFICATION_SUBJECTS as RA_NOTIFICATION_SUBJECTS
from lofar.sas.resourceassignment.resourceassigner.config import RA_NOTIFICATION_BUSNAME, RA_NOTIFICATION_SUBJECTS
from lofar.sas.resourceassignment.ratootdbtaskspecificationpropagator.propagator import RAtoOTDBPropagator
logger = logging.getLogger(__name__)
......@@ -74,7 +73,7 @@ class RATaskStatusChangedListener(RADBBusListener):
self.onTaskScheduled(task['id'], task['otdb_id'], task['mom_id'])
elif new_task['status'] == 'conflict':
self.onTaskScheduled(task['id'], task['otdb_id'], task['mom_id'])
def onTaskScheduled(self, ra_id, otdb_id, mom_id):
logger.info('onTaskScheduled: ra_id=%s otdb_id=%s mom_id=%s' % (ra_id, otdb_id, mom_id))
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment