fixup! feat(hydroflow_lang): add batch(), checking of flo [un]windo…

…wing ops
hydro-project · Nov 27, 2024 · dbf0879 · dbf0879
1 parent e35b34e
commit dbf0879
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/hydroflow/tests/snapshots/surface_loop__flo_syntax@graphvis_dot.snap b/hydroflow/tests/snapshots/surface_loop__flo_syntax@graphvis_dot.snap
@@ -12,7 +12,7 @@ digraph {
     n5v1 [label="(n5v1) batch()", shape=invhouse, fillcolor="#88aaff"]
     n6v1 [label="(n6v1) flatten()", shape=invhouse, fillcolor="#88aaff"]
     n7v1 [label="(n7v1) cross_join::<'static, 'tick>()", shape=invhouse, fillcolor="#88aaff"]
-    n8v1 [label="(n8v1) for_each(|(user, message)| println!(\"notify {} of {}\", user, message))", shape=house, fillcolor="#ffff88"]
+    n8v1 [label="(n8v1) for_each(|(user, message)| {\l    println!(\"{}: notify {} of {}\", context.current_tick(), user, message)\l})\l", shape=house, fillcolor="#ffff88"]
     n9v1 [label="(n9v1) handoff", shape=parallelogram, fillcolor="#ddddff"]
     n10v1 [label="(n10v1) handoff", shape=parallelogram, fillcolor="#ddddff"]
     n4v1 -> n7v1 [label="0"]

diff --git a/hydroflow/tests/snapshots/surface_loop__flo_syntax@graphvis_mermaid.snap b/hydroflow/tests/snapshots/surface_loop__flo_syntax@graphvis_mermaid.snap
@@ -15,7 +15,7 @@ linkStyle default stroke:#aaa
 5v1[\"(5v1) <code>batch()</code>"/]:::pullClass
 6v1[\"(6v1) <code>flatten()</code>"/]:::pullClass
 7v1[\"(7v1) <code>cross_join::&lt;'static, 'tick&gt;()</code>"/]:::pullClass
-8v1[/"(8v1) <code>for_each(|(user, message)| println!(&quot;notify {} of {}&quot;, user, message))</code>"\]:::pushClass
+8v1[/"<div style=text-align:center>(8v1)</div> <code>for_each(|(user, message)| {<br>    println!(&quot;{}: notify {} of {}&quot;, context.current_tick(), user, message)<br>})</code>"\]:::pushClass
 9v1["(9v1) <code>handoff</code>"]:::otherClass
 10v1["(10v1) <code>handoff</code>"]:::otherClass
 4v1-->|0|7v1

diff --git a/hydroflow/tests/surface_loop.rs b/hydroflow/tests/surface_loop.rs
@@ -11,7 +11,7 @@ pub fn test_flo_syntax() {
             // TODO(mingwei): cross_join type negotion should allow us to eliminate `flatten()`.
             users -> batch() -> flatten() -> [0]cp;
             messages -> batch() -> flatten() -> [1]cp;
-            cp = cross_join::<'static, 'tick>() -> for_each(|(user, message)| println!("notify {} of {}", user, message));
+            cp = cross_join::<'static, 'tick>() -> for_each(|(user, message)| println!("{}: notify {} of {}", context.current_tick(), user, message));
         }
     };
     assert_graphvis_snapshots!(df);