replace interchange-based outstanding task count with submit-side str…

…ucture count

parsl/executors/high_throughput/executor.py

@@ -582,7 +582,7 @@ def hold_worker(self, worker_id: str) -> None:
     def outstanding(self) -> int:
         """Returns the count of tasks outstanding across the interchange
         and managers"""
-        return self.command_client.run("OUTSTANDING_C")
+        return len(self.tasks)
 
     @property
     def connected_workers(self) -> int:

parsl/executors/high_throughput/interchange.py

@@ -253,13 +253,7 @@ def _command_server(self) -> NoReturn:
                 logger.debug("Waiting for command request")
                 command_req = self.command_channel.recv_pyobj()
                 logger.debug("Received command request: {}".format(command_req))
-                if command_req == "OUTSTANDING_C":
-                    outstanding = self.pending_task_queue.qsize()
-                    for manager in self._ready_managers.values():
-                        outstanding += len(manager['tasks'])
-                    reply = outstanding
-
-                elif command_req == "CONNECTED_BLOCKS":
+                if command_req == "CONNECTED_BLOCKS":
                     reply = self.connected_block_history
 
                 elif command_req == "WORKERS":

parsl/version.py

@@ -1,3 +1,3 @@
 """Set module version.
 """
-VERSION = '2024.10.07+desc-2024.10.10a'
+VERSION = '2024.10.07+desc-2024.10.10c'