law add_running_marks_dirty

bend-kube-runtime@0.2.0.0 · LAWS.bend:120

import Base
import bend-kube-runtime@0.2.0.0/src/queue.bend as Q

120# Adding a key that is running does not queue it a second time: it is
121# marked dirty, to run again when the current run ends.
122law add_running_marks_dirty:
123  for f: List<&2, String>
124  for b: List<&2, String>
125  for inq: Map<&2, U32>
126  for run: Map<&2, U32>
127  for d: Map<&2, U32>
128  for g: Map<&2, U32>
129  for fl: Map<&2, U32>
130  for n: U32
131  for mx: U32
132  for key: String
133  for running: {Q.Mp.has(run, key) == True{} : Bool}
134  {Q.Queue.add(Q.Queue{f, b, inq, run, d, g, fl, n, mx}, key)
135    == Q.Queue{f, b, inq, run, Q.Mp.on(d, key), Q.Mp.bump(g, key), fl, n, mx} : Q.Queue}