tests.test_dtm_Scheduler.TestScheduler Class Reference

Inheritance diagram for tests.test_dtm_Scheduler.TestScheduler:

Collaboration diagram for tests.test_dtm_Scheduler.TestScheduler:

Public Member Functions
def	setUp (self)
def	tearDown (self)
def	check_task_in_dbi (self, task, state_condition=None)
def	check_task_not_in_dbi (self, task)
def	delete_task_in_dbi (self, task)
def	test_new_task (self)
def	test_update_task_no_pending_task (self)
def	test_update_task_present_in_pending_tasks (self)
def	test_delete_task_present_in_pending_tasts (self)
def	test_delete_task_no_present_in_schedule (self)
def	test_delete_task_present_in_schedule (self)
def	test_resourceAVG_finish_add (self)
def	test_resourceAVG_finish_no_pending_event (self)
def	test_resourceAVG_finish_update (self)
def	test_resourceAVG_resources_exceed (self)
def	test_resourceAVG_insert_thesame_task (self)
def	test_resourceAVG_update_non_exist_task (self)
def	test_get_scheduled_tasks_empty_db (self)
def	test_get_scheduled_tasks_broken_db (self)
def	test_get_scheduled_tasks_select_one_task (self)
def	test_get_scheduler_tasks_all_tasks_selected_by_ee (self)
def	test_get_scheduler_tasks_check_select_order (self)

Public Attributes
	config
	adminServerFake
	pollerManager_mock
	connectionBuilderLight_mock
	dbi_mock
	serverConnection_mock
	resourcesManager_mock
	connections_mock
	scheduler
	eventBuilder
	taskId
	newTask
	updateTask
	deleteTask
	resourceAVG
	resourceAVGEvent
	newTaskEvent
	updateTaskEvent
	deleteTaskEvent
	getScheduledTasksEvent
	getScheduledTasksResponse

Detailed Description

Definition at line 46 of file test_dtm_Scheduler.py.

Member Function Documentation

check_task_in_dbi()

def tests.test_dtm_Scheduler.TestScheduler.check_task_in_dbi	(		self,
			task,
			state_condition = None
	)

Definition at line 96 of file test_dtm_Scheduler.py.

    def check_task_in_dbi(self, task, state_condition=None):
        schedulerTask = SchedulerTask()
        schedulerTask.id = task.id
        lookSchedulerTaskScheme = SchedulerTaskScheme(schedulerTask)         
        resSchedulerTaskScheme = self.scheduler.dbi.fetch(lookSchedulerTaskScheme, "id=%s" % task.id)[0]        
        resTaskLog = resSchedulerTaskScheme._getSchedulerTask()
        
        if task.id == resTaskLog.id:
            if state_condition:
                if resTaskLog.state == state_condition:
                    return True
                else:
                    return False
            return True
        return False

Here is the caller graph for this function:

check_task_not_in_dbi()

def tests.test_dtm_Scheduler.TestScheduler.check_task_not_in_dbi	(		self,
			task
	)

Definition at line 113 of file test_dtm_Scheduler.py.

    def check_task_not_in_dbi(self, task):
        schedulerTask = SchedulerTask()
        schedulerTask.id = task.id
        lookSchedulerTaskScheme = SchedulerTaskScheme(schedulerTask) 
        resSchedulerTaskScheme = self.scheduler.dbi.fetch(lookSchedulerTaskScheme, "id=%s" % task.id)[0]                
        if resSchedulerTaskScheme == None:
            return True
        return False
    

Here is the caller graph for this function:

delete_task_in_dbi()

def tests.test_dtm_Scheduler.TestScheduler.delete_task_in_dbi	(		self,
			task
	)

Definition at line 123 of file test_dtm_Scheduler.py.

    def delete_task_in_dbi(self, task):
        schedulerTask = SchedulerTask()
        schedulerTask.id = task.id
        lookSchedulerTaskScheme = SchedulerTaskScheme(schedulerTask) 
        self.scheduler.dbi.delete(lookSchedulerTaskScheme, "id=%s" % task.id)
        self.scheduler.checkDBIState()
    
    

Here is the caller graph for this function:

setUp()

def tests.test_dtm_Scheduler.TestScheduler.setUp

(

self

)

Definition at line 49 of file test_dtm_Scheduler.py.

    def setUp(self):
        self.config = ConfigParser.RawConfigParser() 
        cfg_section = "Scheduler"
        
        tf = tempfile.NamedTemporaryFile()          
        sql_name = "sqlite:///" +  os.path.basename(tf.name) + "Scheduler.db"               
        
        self.config.add_section(cfg_section)
        self.config.set(cfg_section, Scheduler.SERVER, "Scheduler")
        self.config.set(cfg_section, Scheduler.RESOURCES_MANAGER_CLIENT, "ResourcesManager")        
        self.config.set(cfg_section, "db_name", sql_name)
        
        connectionBuilderLight = ConnectionBuilderLight()
        self.adminServerFake = connectionBuilderLight.build(tr_consts.SERVER_CONNECT, BaseServerManager.ADMIN_CONNECT_ENDPOINT)
                
        self.pollerManager_mock = MagicMock(spec=PollerManager)
        self.connectionBuilderLight_mock = MagicMock(spec=ConnectionBuilderLight )
        
        self.dbi_mock = MagicMock(DBI)
        self.serverConnection_mock = MagicMock(spec=ConnectionLight)
        self.resourcesManager_mock = MagicMock(spec=ConnectionLight)        
        self.connections_mock = [self.serverConnection_mock, self.resourcesManager_mock]
        
        self.connectionBuilderLight_mock.build.side_effect = self.connections_mock
        
        self.scheduler = Scheduler(self.config, self.connectionBuilderLight_mock, self.pollerManager_mock)
        self.eventBuilder = EventBuilder()
        
        self.taskId = 1
        self.newTask = NewTask("ls", self.taskId)
        self.updateTask =  UpdateTask(self.taskId)
        self.deleteTask = DeleteTask(0, self.taskId)
        self.resourceAVG = ResourcesAVG()
        self.resourceAVGEvent = self.eventBuilder.build(EVENT_TYPES.GET_AVG_RESOURCES_RESPONSE, self.resourceAVG)
        self.newTaskEvent = self.eventBuilder.build(EVENT_TYPES.SCHEDULE_TASK, self.newTask)
        self.updateTaskEvent = self.eventBuilder.build(EVENT_TYPES.UPDATE_TASK, self.updateTask)
        self.deleteTaskEvent = self.eventBuilder.build(EVENT_TYPES.DELETE_TASK, self.deleteTask)
        self.getScheduledTasksEvent = self.eventBuilder.build(EVENT_TYPES.GET_SCHEDULED_TASKS, GetScheduledTasks(10))
        self.getScheduledTasksResponse = GetScheduledTasksResponse([])
        
        self.pollerManager_mock.poll.return_value = [self.scheduler.SERVER]
        
     

tearDown()

def tests.test_dtm_Scheduler.TestScheduler.tearDown

(

self

)

Definition at line 92 of file test_dtm_Scheduler.py.

    def tearDown(self): 
        self.adminServerFake.close()

test_delete_task_no_present_in_schedule()

def tests.test_dtm_Scheduler.TestScheduler.test_delete_task_no_present_in_schedule

(

self

)

Definition at line 184 of file test_dtm_Scheduler.py.

    def test_delete_task_no_present_in_schedule(self):
        self.serverConnection_mock.recv.return_value = self.deleteTaskEvent
        
        self.scheduler.poll()
        
        self.serverConnection_mock.send.assert_called_once_with(ANY)
        
        

test_delete_task_present_in_pending_tasts()

def tests.test_dtm_Scheduler.TestScheduler.test_delete_task_present_in_pending_tasts

(

self

)

Definition at line 172 of file test_dtm_Scheduler.py.

    def test_delete_task_present_in_pending_tasts(self):
        #add  pending task
        self.scheduler.waitResourcesTasks[self.taskId] = True
        
        self.serverConnection_mock.recv.return_value = self.deleteTaskEvent
        
        self.scheduler.poll()
        
        self.assertEqual(self.resourcesManager_mock.send.call_count, 0, "event send to resourceManager")
        self.serverConnection_mock.send.assert_called_once_with(ANY)

test_delete_task_present_in_schedule()

def tests.test_dtm_Scheduler.TestScheduler.test_delete_task_present_in_schedule

(

self

)

Definition at line 192 of file test_dtm_Scheduler.py.

    def test_delete_task_present_in_schedule(self):
        self.scheduler.modifyTaskInSchedule(self.newTask)
        self.scheduler.checkDBIState()

        self.serverConnection_mock.recv.return_value = self.deleteTaskEvent
        
        self.scheduler.poll()
        
        self.serverConnection_mock.send.assert_called_once_with(ANY)
        self.assertTrue(self.check_task_not_in_dbi(self.newTask), "task is still in schedule")
        
        self.delete_task_in_dbi(self.newTask)        
        
        

Here is the call graph for this function:

test_get_scheduled_tasks_broken_db()

def tests.test_dtm_Scheduler.TestScheduler.test_get_scheduled_tasks_broken_db

(

self

)

Definition at line 308 of file test_dtm_Scheduler.py.

    def test_get_scheduled_tasks_broken_db(self):
        self.serverConnection_mock.recv.return_value = self.getScheduledTasksEvent 
        expect_response_event = self.eventBuilder.build(EVENT_TYPES.GET_SCHEDULED_TASKS_RESPONSE, self.getScheduledTasksResponse)
        match_event = Matcher(matchGetScheduledTasks, expect_response_event)
        
        self.scheduler.dbi.errorCode = dbi_const.DBI_DELETE_ERROR_CODE
                
        self.scheduler.poll()
                
        self.serverConnection_mock.send.assert_called_once_with(match_event)
        
                

test_get_scheduled_tasks_empty_db()

def tests.test_dtm_Scheduler.TestScheduler.test_get_scheduled_tasks_empty_db

(

self

)

Definition at line 298 of file test_dtm_Scheduler.py.

    def test_get_scheduled_tasks_empty_db(self):
        self.serverConnection_mock.recv.return_value = self.getScheduledTasksEvent 
        expect_response_event = self.eventBuilder.build(EVENT_TYPES.GET_SCHEDULED_TASKS_RESPONSE, self.getScheduledTasksResponse)
        match_event = Matcher(matchGetScheduledTasks, expect_response_event)
                
        self.scheduler.poll()
                
        self.serverConnection_mock.send.assert_called_once_with(match_event)

test_get_scheduled_tasks_select_one_task()

def tests.test_dtm_Scheduler.TestScheduler.test_get_scheduled_tasks_select_one_task

(

self

)

Definition at line 320 of file test_dtm_Scheduler.py.

    def test_get_scheduled_tasks_select_one_task(self):
        self.scheduler.modifyTaskInSchedule(self.newTask) 
        self.getScheduledTasksResponse = GetScheduledTasksResponse([self.newTask.id])
        
        self.serverConnection_mock.recv.return_value = self.getScheduledTasksEvent 
        expect_response_event = self.eventBuilder.build(EVENT_TYPES.GET_SCHEDULED_TASKS_RESPONSE, self.getScheduledTasksResponse)
        match_event = Matcher(matchGetScheduledTasks, expect_response_event)
        
        self.scheduler.poll()
                
        self.serverConnection_mock.send.assert_called_once_with(match_event)
        self.check_task_in_dbi(self.newTask, SELECTED_EE)
        
        self.delete_task_in_dbi(self.newTask)
        
        

Here is the call graph for this function:

test_get_scheduler_tasks_all_tasks_selected_by_ee()

def tests.test_dtm_Scheduler.TestScheduler.test_get_scheduler_tasks_all_tasks_selected_by_ee

(

self

)

Definition at line 336 of file test_dtm_Scheduler.py.

    def test_get_scheduler_tasks_all_tasks_selected_by_ee(self):
        schedulerTask = SchedulerTask()
        schedulerTask.id = self.newTask.id
        schedulerTask.state = SELECTED_EE
        self.scheduler.dbi.insert(SchedulerTaskScheme(schedulerTask))        
        self.scheduler.checkDBIState()
        
        self.serverConnection_mock.recv.return_value = self.getScheduledTasksEvent 
        expect_response_event = self.eventBuilder.build(EVENT_TYPES.GET_SCHEDULED_TASKS_RESPONSE, self.getScheduledTasksResponse)
        match_event = Matcher(matchGetScheduledTasks, expect_response_event)
        
        self.scheduler.poll()
                
        self.serverConnection_mock.send.assert_called_once_with(match_event)
        
        self.delete_task_in_dbi(self.newTask)
        

Here is the call graph for this function:

test_get_scheduler_tasks_check_select_order()

def tests.test_dtm_Scheduler.TestScheduler.test_get_scheduler_tasks_check_select_order

(

self

)

Definition at line 354 of file test_dtm_Scheduler.py.

    def test_get_scheduler_tasks_check_select_order(self):
        tasks = [self.newTask, NewTask("ls", 2), NewTask("ls", 3)]
        for task in tasks: 
            self.scheduler.modifyTaskInSchedule(task)
            self.scheduler.checkDBIState()
            
        self.getScheduledTasksResponse = GetScheduledTasksResponse([self.newTask.id, 2, 3])        
        self.serverConnection_mock.recv.return_value = self.getScheduledTasksEvent 
        expect_response_event = self.eventBuilder.build(EVENT_TYPES.GET_SCHEDULED_TASKS_RESPONSE, self.getScheduledTasksResponse)
        match_event = Matcher(matchGetScheduledTasks, expect_response_event)
        
        self.scheduler.poll()
                
        self.serverConnection_mock.send.assert_called_once_with(match_event)
        for task in tasks:
            self.check_task_in_dbi(task, SELECTED_EE)
        
        for task in tasks:
            self.delete_task_in_dbi(task)

test_new_task()

def tests.test_dtm_Scheduler.TestScheduler.test_new_task

(

self

)

Definition at line 131 of file test_dtm_Scheduler.py.

    def test_new_task(self):
        self.serverConnection_mock.recv.return_value = self.newTaskEvent
        
        expect_GetAVGResourceEvent = self.eventBuilder.build(EVENT_TYPES.GET_AVG_RESOURCES, None)
        expect_GetAVGResourceEvent.uid = self.newTaskEvent.uid
        
        match_event = Matcher(matchGetAVGResourceEvent, expect_GetAVGResourceEvent)
        
        self.scheduler.poll()
        
        self.assertEqual(self.scheduler.waitResourcesTasks[self.newTask.id], True, "")
        self.assertEqual(self.scheduler.waitResourcesEvents[self.newTaskEvent.uid], self.newTaskEvent, "")
        self.resourcesManager_mock.send.assert_called_once_with(match_event)
        
        

test_resourceAVG_finish_add()

def tests.test_dtm_Scheduler.TestScheduler.test_resourceAVG_finish_add

(

self

)

Definition at line 206 of file test_dtm_Scheduler.py.

    def test_resourceAVG_finish_add(self):
        self.newTaskEvent.connect_name = Scheduler.SERVER
        self.scheduler.addPendingEvent(self.newTaskEvent)
        self.resourceAVGEvent.uid = self.newTaskEvent.uid
        
        self.serverConnection_mock.recv.return_value = self.resourceAVGEvent        
        match_event = Matcher(matchEventUID, self.newTaskEvent)
        
        self.scheduler.poll()

        self.assertEqual(len(self.scheduler.waitResourcesTasks), 0, "")
        self.assertEqual(len(self.scheduler.waitResourcesEvents), 0, "")
        self.assertTrue(self.check_task_in_dbi(self.newTask), "")        
        self.serverConnection_mock.send.assert_called_once_with(match_event)
        
        self.delete_task_in_dbi(self.newTask)        
        

Here is the call graph for this function:

test_resourceAVG_finish_no_pending_event()

def tests.test_dtm_Scheduler.TestScheduler.test_resourceAVG_finish_no_pending_event

(

self

)

Definition at line 224 of file test_dtm_Scheduler.py.

    def test_resourceAVG_finish_no_pending_event(self):
        self.serverConnection_mock.recv.return_value = self.resourceAVGEvent        
        match_event = Matcher(matchEventUID, self.newTaskEvent)
        
        self.scheduler.poll()

test_resourceAVG_finish_update()

def tests.test_dtm_Scheduler.TestScheduler.test_resourceAVG_finish_update

(

self

)

Definition at line 231 of file test_dtm_Scheduler.py.

    def test_resourceAVG_finish_update(self):
        self.updateTaskEvent.connect_name = Scheduler.SERVER
        self.scheduler.addPendingEvent(self.updateTaskEvent)
        self.scheduler.modifyTaskInSchedule(self.newTask)
        self.resourceAVGEvent.uid = self.updateTaskEvent.uid
                        
        self.serverConnection_mock.recv.return_value = self.resourceAVGEvent        
        match_event = Matcher(matchEventUID, self.updateTaskEvent)
        
        self.scheduler.poll()

        self.assertEqual(len(self.scheduler.waitResourcesTasks), 0, "")
        self.assertEqual(len(self.scheduler.waitResourcesEvents), 0, "")
        self.assertTrue(self.check_task_in_dbi(self.updateTask), "")        
        self.serverConnection_mock.send.assert_called_once_with(match_event)
        
        self.delete_task_in_dbi(self.newTask)        
        
        

Here is the call graph for this function:

test_resourceAVG_insert_thesame_task()

def tests.test_dtm_Scheduler.TestScheduler.test_resourceAVG_insert_thesame_task

(

self

)

Definition at line 266 of file test_dtm_Scheduler.py.

    def test_resourceAVG_insert_thesame_task(self):
        self.newTaskEvent.connect_name = Scheduler.SERVER
        self.scheduler.addPendingEvent(self.newTaskEvent)
        self.scheduler.modifyTaskInSchedule(self.newTask)
        self.resourceAVGEvent.uid = self.newTaskEvent.uid
        
        self.serverConnection_mock.recv.return_value = self.resourceAVGEvent
        
        self.scheduler.poll()

        self.assertEqual(len(self.scheduler.waitResourcesTasks), 0, "")
        self.assertEqual(len(self.scheduler.waitResourcesEvents), 0, "")
        self.assertTrue(self.check_task_in_dbi(self.updateTask), "")        
        self.serverConnection_mock.send.assert_called_once_with(ANY)
        
        self.delete_task_in_dbi(self.newTask)
        
        

Here is the call graph for this function:

test_resourceAVG_resources_exceed()

def tests.test_dtm_Scheduler.TestScheduler.test_resourceAVG_resources_exceed

(

self

)

Definition at line 250 of file test_dtm_Scheduler.py.

    def test_resourceAVG_resources_exceed(self):
        self.newTaskEvent.connect_name = Scheduler.SERVER
        self.scheduler.addPendingEvent(self.newTaskEvent)
        self.resourceAVGEvent.uid = self.newTaskEvent.uid
        self.resourceAVG.cpu = 200
        
        self.serverConnection_mock.recv.return_value = self.resourceAVGEvent 
        
        self.scheduler.poll()

        self.assertEqual(len(self.scheduler.waitResourcesTasks), 0, "")
        self.assertEqual(len(self.scheduler.waitResourcesEvents), 0, "")
        self.assertTrue(self.check_task_not_in_dbi(self.updateTask), "")        
        self.serverConnection_mock.send.assert_called_once_with(ANY)
        
        

Here is the call graph for this function:

test_resourceAVG_update_non_exist_task()

def tests.test_dtm_Scheduler.TestScheduler.test_resourceAVG_update_non_exist_task

(

self

)

Definition at line 284 of file test_dtm_Scheduler.py.

    def test_resourceAVG_update_non_exist_task(self):
        self.updateTaskEvent.connect_name = Scheduler.SERVER
        self.scheduler.addPendingEvent(self.updateTaskEvent)
        self.resourceAVGEvent.uid = self.updateTaskEvent.uid
        
        self.serverConnection_mock.recv.return_value = self.resourceAVGEvent
        
        self.scheduler.poll()
        
        self.assertEqual(len(self.scheduler.waitResourcesTasks), 0, "")
        self.assertEqual(len(self.scheduler.waitResourcesEvents), 0, "")
        self.serverConnection_mock.send.assert_called_once_with(ANY)

test_update_task_no_pending_task()

def tests.test_dtm_Scheduler.TestScheduler.test_update_task_no_pending_task

(

self

)

Definition at line 146 of file test_dtm_Scheduler.py.

    def test_update_task_no_pending_task(self):
        self.serverConnection_mock.recv.return_value = self.updateTaskEvent

        expect_GetAVGResourceEvent = self.eventBuilder.build(EVENT_TYPES.GET_AVG_RESOURCES, None)
        expect_GetAVGResourceEvent.uid = self.updateTaskEvent.uid        
        match_event = Matcher(matchGetAVGResourceEvent, expect_GetAVGResourceEvent)
                
        self.scheduler.poll()

        self.assertEqual(self.scheduler.waitResourcesTasks[self.updateTask.id], True, "")
        self.assertEqual(self.scheduler.waitResourcesEvents[self.updateTaskEvent.uid], self.updateTaskEvent, "")
        self.resourcesManager_mock.send.assert_called_once_with(match_event)
        
        

test_update_task_present_in_pending_tasks()

def tests.test_dtm_Scheduler.TestScheduler.test_update_task_present_in_pending_tasks

(

self

)

Definition at line 160 of file test_dtm_Scheduler.py.

    def test_update_task_present_in_pending_tasks(self):
        #add  pending task
        self.scheduler.waitResourcesTasks[self.taskId] = True
                
        self.serverConnection_mock.recv.return_value = self.updateTaskEvent

        self.scheduler.poll()
        
        self.assertEqual(self.resourcesManager_mock.send.call_count, 0, "event send to resourceManager")
        self.serverConnection_mock.send.assert_called_once_with(ANY)
        
        

Member Data Documentation

adminServerFake

tests.test_dtm_Scheduler.TestScheduler.adminServerFake

Definition at line 62 of file test_dtm_Scheduler.py.

config

tests.test_dtm_Scheduler.TestScheduler.config

Definition at line 50 of file test_dtm_Scheduler.py.

connectionBuilderLight_mock

tests.test_dtm_Scheduler.TestScheduler.connectionBuilderLight_mock

Definition at line 65 of file test_dtm_Scheduler.py.

connections_mock

tests.test_dtm_Scheduler.TestScheduler.connections_mock

Definition at line 70 of file test_dtm_Scheduler.py.

dbi_mock

tests.test_dtm_Scheduler.TestScheduler.dbi_mock

Definition at line 67 of file test_dtm_Scheduler.py.

deleteTask

tests.test_dtm_Scheduler.TestScheduler.deleteTask

Definition at line 80 of file test_dtm_Scheduler.py.

deleteTaskEvent

tests.test_dtm_Scheduler.TestScheduler.deleteTaskEvent

Definition at line 85 of file test_dtm_Scheduler.py.

eventBuilder

tests.test_dtm_Scheduler.TestScheduler.eventBuilder

Definition at line 75 of file test_dtm_Scheduler.py.

getScheduledTasksEvent

tests.test_dtm_Scheduler.TestScheduler.getScheduledTasksEvent

Definition at line 86 of file test_dtm_Scheduler.py.

getScheduledTasksResponse

tests.test_dtm_Scheduler.TestScheduler.getScheduledTasksResponse

Definition at line 87 of file test_dtm_Scheduler.py.

newTask

tests.test_dtm_Scheduler.TestScheduler.newTask

Definition at line 78 of file test_dtm_Scheduler.py.

newTaskEvent

tests.test_dtm_Scheduler.TestScheduler.newTaskEvent

Definition at line 83 of file test_dtm_Scheduler.py.

pollerManager_mock

tests.test_dtm_Scheduler.TestScheduler.pollerManager_mock

Definition at line 64 of file test_dtm_Scheduler.py.

resourceAVG

tests.test_dtm_Scheduler.TestScheduler.resourceAVG

Definition at line 81 of file test_dtm_Scheduler.py.

resourceAVGEvent

tests.test_dtm_Scheduler.TestScheduler.resourceAVGEvent

Definition at line 82 of file test_dtm_Scheduler.py.

resourcesManager_mock

tests.test_dtm_Scheduler.TestScheduler.resourcesManager_mock

Definition at line 69 of file test_dtm_Scheduler.py.

scheduler

tests.test_dtm_Scheduler.TestScheduler.scheduler

Definition at line 74 of file test_dtm_Scheduler.py.

serverConnection_mock

tests.test_dtm_Scheduler.TestScheduler.serverConnection_mock

Definition at line 68 of file test_dtm_Scheduler.py.

taskId

tests.test_dtm_Scheduler.TestScheduler.taskId

Definition at line 77 of file test_dtm_Scheduler.py.

updateTask

tests.test_dtm_Scheduler.TestScheduler.updateTask

Definition at line 79 of file test_dtm_Scheduler.py.

updateTaskEvent

tests.test_dtm_Scheduler.TestScheduler.updateTaskEvent

Definition at line 84 of file test_dtm_Scheduler.py.

---

The documentation for this class was generated from the following file:

• sources/hce/tests/test_dtm_Scheduler.py