diff --git a/parsl/executors/status_handling.py b/parsl/executors/status_handling.py index 13ddef1256..90773591b6 100644 --- a/parsl/executors/status_handling.py +++ b/parsl/executors/status_handling.py @@ -174,6 +174,16 @@ def _filter_scale_in_ids(self, to_kill, killed): # Filters first iterable by bool values in second return list(compress(to_kill, killed)) + def scale_out_facade(self, n: int) -> List[str]: + block_ids = self._scale_out(n) + if block_ids is not None: + new_status = {} + for block_id in block_ids: + new_status[block_id] = JobStatus(JobState.PENDING) + self.send_monitoring_info(new_status) + self._status.update(new_status) + return block_ids + def _scale_out(self, blocks: int = 1) -> List[str]: """Scales out the number of blocks by "blocks" """ @@ -327,13 +337,3 @@ def scale_in_facade(self, n: int, max_idletime: Optional[float] = None) -> List[ del self._status[block_id] self.send_monitoring_info(new_status) return block_ids - - def scale_out_facade(self, n: int) -> List[str]: - block_ids = self._scale_out(n) - if block_ids is not None: - new_status = {} - for block_id in block_ids: - new_status[block_id] = JobStatus(JobState.PENDING) - self.send_monitoring_info(new_status) - self._status.update(new_status) - return block_ids