rename status as an authoritative status regenerator

it can be subclassed to add in executor-specific status (as happens with htex)

Author: benclifford

parsl/executors/high_throughput/executor.py

@@ -787,8 +787,8 @@ def _get_launch_command(self, block_id: str) -> str:
         launch_cmd = self.launch_cmd.format(block_id=block_id)
         return launch_cmd
 
-    def status(self) -> Dict[str, JobStatus]:
-        job_status = super().status()
+    def _regenerate_combined_status(self) -> Dict[str, JobStatus]:
+        job_status = super()._regenerate_combined_status()
         connected_blocks = self.connected_blocks()
         for job_id in job_status:
             job_info = job_status[job_id]

parsl/executors/status_handling.py

@@ -76,7 +76,7 @@ def __init__(self, *,
 
         # errors can happen during the submit call to the provider; this is used
         # to keep track of such errors so that they can be handled in one place
-        # together with errors reported by status()
+        # together with errors reported by _regenerate_combined_status()
         self._simulated_status: Dict[str, JobStatus] = {}
 
         # this stores an approximation (sometimes delayed) of the latest status
@@ -106,7 +106,7 @@ def status_polling_interval(self):
         In practice, at least given the current situation, the executor uses a single task provider
         and this method is a delegate to the corresponding method in the provider.
 
-        :return: the number of seconds to wait between calls to status() or zero if no polling
+        :return: the number of seconds to wait between calls to _regenerate_combined_status() or zero if no polling
                  should be done
         """
         if self._provider is None:
@@ -296,7 +296,7 @@ def poll_facade(self) -> None:
         now = time.time()
         if now >= self._last_poll_time + self.status_polling_interval:
             previous_status = self._status
-            self._status = self.status()
+            self._status = self._regenerate_combined_status()
             self._last_poll_time = now
             delta_status = {}
             for block_id in self._status:
@@ -307,7 +307,7 @@ def poll_facade(self) -> None:
             if delta_status:
                 self.send_monitoring_info(delta_status)
 
-    def status(self) -> Dict[str, JobStatus]:
+    def _regenerate_combined_status(self) -> Dict[str, JobStatus]:
         """Return the status of all jobs/blocks currently known to this executor.
 
         :return: a dictionary mapping block ids (in string) to job status