Skip to content

Commit 1badbe4

Browse files
committed
CHANGES:
- Scheduler: added no_reload option to avoid reload on 'load' - Scheduler: reworked documentation
1 parent c93173d commit 1badbe4

File tree

6 files changed

+174
-64
lines changed

6 files changed

+174
-64
lines changed

core/data/impl/serverimpl.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -945,7 +945,7 @@ async def replaceMission(self, mission_id: int, path: str) -> list[str]:
945945
return self.settings['missionList']
946946

947947
async def loadMission(self, mission: Union[int, str], modify_mission: Optional[bool] = True,
948-
use_orig: Optional[bool] = True) -> bool:
948+
use_orig: Optional[bool] = True, no_reload: Optional[bool] = False) -> Optional[bool]:
949949
start_index = int(self.settings.get('listStartIndex', 1))
950950
mission_list = self.settings['missionList']
951951
# check if we re-load the running mission
@@ -988,6 +988,8 @@ async def loadMission(self, mission: Union[int, str], modify_mission: Optional[b
988988
try:
989989
idx = mission_list.index(filename) + 1
990990
if idx == start_index:
991+
if no_reload:
992+
return None
991993
rc = await self.send_to_dcs_sync({"command": "startMission", "filename": filename})
992994
else:
993995
rc = await self.send_to_dcs_sync({"command": "startMission", "id": idx})

core/data/proxy/serverproxy.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -337,7 +337,7 @@ async def replaceMission(self, mission_id: int, path: str) -> list[str]:
337337
return data['return']
338338

339339
async def loadMission(self, mission: Union[int, str], modify_mission: Optional[bool] = True,
340-
use_orig: Optional[bool] = True) -> bool:
340+
use_orig: Optional[bool] = True, no_reload: Optional[bool] = False) -> Optional[bool]:
341341
timeout = 180 if not self.node.slow_system else 300
342342
data = await self.bus.send_to_node_sync({
343343
"command": "rpc",
@@ -347,7 +347,8 @@ async def loadMission(self, mission: Union[int, str], modify_mission: Optional[b
347347
"params": {
348348
"mission": mission,
349349
"modify_mission": modify_mission,
350-
"use_orig": use_orig
350+
"use_orig": use_orig,
351+
"no_reload": no_reload
351352
}
352353
}, timeout=timeout, node=self.node.name)
353354
return data['return']

core/data/server.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -358,7 +358,7 @@ async def replaceMission(self, mission_id: int, path: str) -> list[str]:
358358
raise NotImplementedError()
359359

360360
async def loadMission(self, mission: Union[int, str], modify_mission: Optional[bool] = True,
361-
use_orig: Optional[bool] = True) -> bool:
361+
use_orig: Optional[bool] = True, no_reload: Optional[bool] = False) -> Optional[bool]:
362362
raise NotImplementedError()
363363

364364
async def loadNextMission(self, modify_mission: Optional[bool] = True, use_orig: Optional[bool] = True) -> bool:

0 commit comments

Comments
 (0)