Skip to content

Commit

Permalink
Merge branch 'master' into rjmello-ix-proc-shell
Browse files Browse the repository at this point in the history
  • Loading branch information
rjmello authored Jul 28, 2024
2 parents 255af0a + 1652304 commit a544153
Showing 1 changed file with 10 additions and 10 deletions.
20 changes: 10 additions & 10 deletions parsl/executors/status_handling.py
Original file line number Diff line number Diff line change
Expand Up @@ -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"
"""
Expand Down Expand Up @@ -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

0 comments on commit a544153

Please sign in to comment.