diff --git a/src/core/pyros_django/observation_manager/AgentImagesProcessor.py b/src/core/pyros_django/observation_manager/AgentImagesProcessor.py index 6d7afcf..64488cf 100755 --- a/src/core/pyros_django/observation_manager/AgentImagesProcessor.py +++ b/src/core/pyros_django/observation_manager/AgentImagesProcessor.py @@ -37,7 +37,8 @@ class AgentImagesProcessor(Agent): # TODO: Redefine valid timeout _AGENT_SPECIFIC_COMMANDS = { # Format : “cmd_name” : (timeout, exec_mode) - + + "do_create_loadseq_1" : (60, Agent.EXEC_MODE.SEQUENTIAL, ''), "do_create_test_images_1" : (60, Agent.EXEC_MODE.SEQUENTIAL, ''), "do_create_test_images_2" : (60, Agent.EXEC_MODE.SEQUENTIAL, ''), "do_stop_current_processing" : (60, Agent.EXEC_MODE.SEQUENTIAL, ''), @@ -48,7 +49,7 @@ class AgentImagesProcessor(Agent): # AgentCmd.CMD_STATUS_CODE.CMD_EXECUTED _TEST_COMMANDS_LIST = [ # Format : ("self cmd_name cmd_args", timeout, "expected_result", expected_status), - (True, "self do_create_test_images_1", 200, '', Agent.CMD_STATUS.CMD_EXECUTED), + (True, "self do_create_loadseq_1", 200, '', Agent.CMD_STATUS.CMD_EXECUTED), (True, "self do_stop asap", 500, "STOPPING", Agent.CMD_STATUS.CMD_EXECUTED), ] @@ -129,6 +130,9 @@ class AgentImagesProcessor(Agent): def do_stop_current_processing(self): pass + def do_create_loadseq_1(self): + self._create_loadseq_1() + def do_create_test_images_1(self): self._create_test_images_1() @@ -276,6 +280,16 @@ class AgentImagesProcessor(Agent): Internal methods ================================================================= """ + def _create_test_loadseq_1(self): + try: + # === Define an image to test the processing and copy it in incoming directory + self._file_ima_test = os.path.join(self._path_data_root,"vendor/guitastro/tests/data/m57.fit") + file_in = self._file_ima_test + file_out = f"{self._paths['ima_incoming']}/m57.fit" + shutil.copyfile(file_in, file_out) + self._filename_manager.naming("") + except: + raise def _create_test_images_1(self): try: -- libgit2 0.21.2