wip

cylc · May 21, 2024 · 437f710 · 437f710
1 parent f524833
commit 437f710
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/cylc/flow/task_job_mgr.py b/cylc/flow/task_job_mgr.py
@@ -450,6 +450,7 @@ def submit_task_jobs(self, workflow, itasks, curve_auth,
             for itask in itasks:
                 # Log and persist
                 LOG.debug(f"[{itask}] host={host}")
+                breakpoint()
                 self.workflow_db_mgr.put_insert_task_jobs(itask, {
                     'flow_nums': serialise(itask.flow_nums),
                     'is_manual_submit': itask.is_manual_submit,
@@ -1100,6 +1101,7 @@ def _prep_submit_task_job(
             * itask - preparation complete.
             * None - preparation in progress.
             * False - preparation failed.
+            * True - preparation failed because not platforms were found.
 
         """
         if itask.local_job_file_path:
@@ -1197,6 +1199,7 @@ def _prep_submit_task_job(
                     self.bad_hosts -= set(itask.platform['hosts'])
                     self.bad_hosts -= self.bad_hosts_to_clear
                     self.bad_hosts_to_clear.clear()
+                    self._set_retry_timers(itask, rtconfig)
                     self._prep_submit_task_job_error(
                         workflow, itask, '(no platforms available)', exc)
                     return True
@@ -1240,6 +1243,7 @@ def _prep_submit_task_job(
 
     def _prep_submit_task_job_error(self, workflow, itask, action, exc):
         """Helper for self._prep_submit_task_job. On error."""
+        # breakpoint(header=f'>>> {itask=}  {exc=}  {action=}')
         log_task_job_activity(
             SubProcContext(self.JOBS_SUBMIT, action, err=exc, ret_code=1),
             workflow,