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

TMSS-652: do not import at top of file before django is configured

parent 76ad4252
No related branches found
No related tags found
No related merge requests found
......@@ -28,7 +28,6 @@ from lofar.messaging.messagebus import ToBus
from lofar.sas.tmss.client.tmssbuslistener import *
from lofar.common import dbcredentials
from lofar.common.util import single_line_with_single_spaces
from lofar.sas.tmss.tmss.tmssapp.models import Subtask, SchedulingUnitBlueprint, TaskBlueprint
from distutils.util import strtobool
......@@ -177,6 +176,7 @@ class TMSSPGListener(PostgresListener):
def onSubTaskStateUpdated(self, payload = None):
payload_dict = json.loads(payload)
# send notification for this subtask...
from lofar.sas.tmss.tmss.tmssapp.models import Subtask
subtask = Subtask.objects.get(id=payload_dict['id'])
self._sendNotification(TMSS_SUBTASK_STATUS_EVENT_PREFIX+'.'+subtask.state.value.capitalize(),
{'id': subtask.id, 'status': subtask.state.value})
......@@ -207,6 +207,8 @@ class TMSSPGListener(PostgresListener):
if isinstance(payload, str):
payload = json.loads(payload)
from lofar.sas.tmss.tmss.tmssapp.models import TaskBlueprint
task_blueprint = TaskBlueprint.objects.get(id=payload['id'])
self._sendNotification(TMSS_SCHEDULINGUNITBLUEPRINT_OBJECT_EVENT_PREFIX+'.Updated', {'id': task_blueprint.scheduling_unit_blueprint.id})
......@@ -227,6 +229,8 @@ class TMSSPGListener(PostgresListener):
if isinstance(payload, str):
payload = json.loads(payload)
from lofar.sas.tmss.tmss.tmssapp.models import SchedulingUnitBlueprint
scheduling_unit_blueprint = SchedulingUnitBlueprint.objects.get(id=payload['id'])
if not scheduling_unit_blueprint.can_proceed:
......
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