feat: Asynchronous Streaming for Source and Sink in Numaflow Core (#2251

) Signed-off-by: Yashash H L <[email protected]> Signed-off-by: Vigith Maurice <[email protected]> Co-authored-by: Vigith Maurice <[email protected]>
numaproj · Dec 4, 2024 · 2530bad · 2530bad
1 parent b31380b
commit 2530bad
Show file tree

Hide file tree

Showing 44 changed files with 3,997 additions and 3,298 deletions.
diff --git a/examples/21-simple-mono-vertex.yaml b/examples/21-simple-mono-vertex.yaml
@@ -14,4 +14,4 @@ spec:
   sink:
     udsink:
       container:
-        image: quay.io/numaio/numaflow-rs/sink-log:stable
+        image: quay.io/numaio/numaflow-rs/sink-log:stable
diff --git a/rust/.rustfmt.toml b/rust/.rustfmt.toml
@@ -1 +1 @@
-edition = "2021"
+edition = "2021"