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

Merge branch 'TMSS-1689' into 'master'

TMSS-1689: add one minute to TMSS reservations that block time for MoM observations

Closes TMSS-1689

See merge request !927
parents bfe2f3d1 bc8470f6
No related branches found
No related tags found
1 merge request!927TMSS-1689: add one minute to TMSS reservations that block time for MoM observations
...@@ -27,6 +27,7 @@ logger = logging.getLogger(__name__) ...@@ -27,6 +27,7 @@ logger = logging.getLogger(__name__)
import requests import requests
from dateutil import parser from dateutil import parser
from datetime import timedelta
import json import json
from lofar.common import isProductionEnvironment, isTestEnvironment from lofar.common import isProductionEnvironment, isTestEnvironment
from lofar.common.util import waitForInterrupt from lofar.common.util import waitForInterrupt
...@@ -158,8 +159,8 @@ class RAEventMessageHandlerForTMSSSynchronization(RAEventMessageHandler): ...@@ -158,8 +159,8 @@ class RAEventMessageHandlerForTMSSSynchronization(RAEventMessageHandler):
"description": "A reservation while OTDB observation %s %s %s is observing" % (ra_task['project_name'], ra_task['otdb_id'], ra_task['description']), "description": "A reservation while OTDB observation %s %s %s is observing" % (ra_task['project_name'], ra_task['otdb_id'], ra_task['description']),
"specifications_doc": specifications_doc, "specifications_doc": specifications_doc,
"specifications_template": self._tmss_client.get_full_url_for_path('/reservation_template/1'), "specifications_template": self._tmss_client.get_full_url_for_path('/reservation_template/1'),
"start_time": ra_task['starttime'], "start_time": (parser.parse(ra_task['starttime'], ignoretz=True) - timedelta(minutes=1)).isoformat(), # add one minute so that TMSS stops early enough before MoM starts
"stop_time": ra_task['endtime'] "stop_time": (parser.parse(ra_task['endtime'], ignoretz=True) + timedelta(minutes=1)).isoformat() # add one minute so that TMSS does not start something else too soon after MoM finishes
} }
self._tmss_client.post_to_path_and_get_result_as_json_object('/reservation', json_data=reservation) self._tmss_client.post_to_path_and_get_result_as_json_object('/reservation', json_data=reservation)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment