First hack at a dupl job submission fix.

cylc · Sep 2, 2024 · 0e25d1a · 0e25d1a
1 parent 574361b
commit 0e25d1a
Showing 1 changed file with 11 additions and 6 deletions.
diff --git a/cylc/flow/subprocpool.py b/cylc/flow/subprocpool.py
@@ -348,12 +348,17 @@ def put_command(
                 callback_255=callback_255, callback_255_args=callback_255_args
             )
         else:
-            self.queuings.append(
-                [
-                    ctx, bad_hosts, callback, callback_args,
-                    callback_255, callback_255_args
-                ]
-            )
+            if (
+                not any(iq[0].cmd == ctx.cmd for iq in self.queuings) and
+                not any(ir[1].cmd == ctx.cmd for ir in self.runnings)
+            ):
+                # Queue it if not already queued or running.
+                self.queuings.append(
+                    [
+                        ctx, bad_hosts, callback, callback_args,
+                        callback_255, callback_255_args
+                    ]
+                )
 
     @classmethod
     def run_command(cls, ctx):