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

TMSS-190: in preparation of dynamic scheduling, renamed the...

TMSS-190: in preparation of dynamic scheduling, renamed the tmss_subtask_scheduling_service to tmss_scheduling_service so we can add SchedulingUnt/TaskBlueprint scheduling to it. Extended the t_subtask_scheduling_service.py test with a TMSS-152 SchedulingUnit of UC1, and check if the whole graph of 13 subtasks is automatically scheduled when the predecessors finish
parents 5677c64d faf1eb0e
Branches
Tags
1 merge request!252Resolve TMSS-190
...@@ -17,15 +17,15 @@ ...@@ -17,15 +17,15 @@
# You should have received a copy of the GNU General Public License along # You should have received a copy of the GNU General Public License along
# with the LOFAR software suite. If not, see <http://www.gnu.org/licenses/>. # with the LOFAR software suite. If not, see <http://www.gnu.org/licenses/>.
import os import os
from optparse import OptionParser from optparse import OptionParser
import logging import logging
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
from lofar.sas.tmss.services.subtask_scheduling import create_subtask_scheduling_service
from lofar.common.util import waitForInterrupt from lofar.common.util import waitForInterrupt
from lofar.messaging.config import DEFAULT_BUSNAME, DEFAULT_BROKER from lofar.messaging.config import DEFAULT_BROKER, DEFAULT_BUSNAME
from lofar.sas.tmss.services.subtask_scheduling import create_subtask_scheduling_service
def main(): def main():
# make sure we run in UTC timezone # make sure we run in UTC timezone
...@@ -35,7 +35,7 @@ def main(): ...@@ -35,7 +35,7 @@ def main():
# Check the invocation arguments # Check the invocation arguments
parser = OptionParser('%prog [options]', parser = OptionParser('%prog [options]',
description='run the tmss_scheduling_service which automatically schedules the defined successor tasks for finished subtasks') description='run the tmss_subtask_scheduling_service which automatically schedules the defined successor tasks for finished subtasks')
parser.add_option('-q', '--broker', dest='broker', type='string', default=DEFAULT_BROKER, help='Address of the messaging broker, default: %default') parser.add_option('-q', '--broker', dest='broker', type='string', default=DEFAULT_BROKER, help='Address of the messaging broker, default: %default')
parser.add_option('--exchange', dest='exchange', type='string', default=DEFAULT_BUSNAME, help='Name of the exchange on the messaging broker, default: %default') parser.add_option('--exchange', dest='exchange', type='string', default=DEFAULT_BUSNAME, help='Name of the exchange on the messaging broker, default: %default')
parser.add_option('-t', '--tmss_client_credentials_id', dest='tmss_client_credentials_id', type='string', parser.add_option('-t', '--tmss_client_credentials_id', dest='tmss_client_credentials_id', type='string',
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment