pub fn insert_async_deadlines(
sub_graph: &mut GraphProto,
) -> Result<(), CompileError>Expand description
Insert a DeadlineCheck upstream of every deadline_ns-bearing
node in sub_graph. Pure (the input graph is mutated in place
but the function has no side effects beyond that).
The DeadlineCheck writes to a sibling input slot
<protected>#__trigger_deadline; the engine fires the protected
node only after every input (original payloads plus the new
trigger slot) has been filled.