diff --git a/parsl/dataflow/dflow.py b/parsl/dataflow/dflow.py index 86d91c0d21..5b2502ceec 100644 --- a/parsl/dataflow/dflow.py +++ b/parsl/dataflow/dflow.py @@ -614,6 +614,13 @@ def check_staging_inhibited(kwargs: Dict[str, Any]) -> bool: return kwargs.get('_parsl_staging_inhibit', False) def launch_if_ready(self, task_record: TaskRecord) -> None: + """schedules a task record for re-inspection to see if it is ready + for launch. The call will return immediately, asynchronous to + whether than check and launch has happened or not. + """ + self.dependency_launch_pool.submit(self._launch_if_ready_async, task_record) + + def _launch_if_ready_async(self, task_record: TaskRecord) -> None: """ launch_if_ready will launch the specified task, if it is ready to run (for example, without dependencies, and in pending state).