Skip to content

Commit

Permalink
Adjust rust dataflow example to use new top-level fields
Browse files Browse the repository at this point in the history
  • Loading branch information
phil-opp committed May 22, 2024
1 parent e975650 commit 8c1412e
Showing 1 changed file with 15 additions and 18 deletions.
33 changes: 15 additions & 18 deletions examples/rust-dataflow/dataflow.yml
Original file line number Diff line number Diff line change
@@ -1,12 +1,11 @@
nodes:
- id: rust-node
custom:
build: cargo build -p rust-dataflow-example-node
source: ../../target/debug/rust-dataflow-example-node
inputs:
tick: dora/timer/millis/10
outputs:
- random
build: cargo build -p rust-dataflow-example-node
path: ../../target/debug/rust-dataflow-example-node
inputs:
tick: dora/timer/millis/10
outputs:
- random
- id: rust-status-node
custom:
build: cargo build -p rust-dataflow-example-status-node
Expand All @@ -17,15 +16,13 @@ nodes:
outputs:
- status
- id: rust-sink
custom:
build: cargo build -p rust-dataflow-example-sink
source: ../../target/debug/rust-dataflow-example-sink
inputs:
message: rust-status-node/status
build: cargo build -p rust-dataflow-example-sink
path: ../../target/debug/rust-dataflow-example-sink
inputs:
message: rust-status-node/status
- id: dora-record
custom:
build: cargo build -p dora-record
source: ../../target/debug/dora-record
inputs:
message: rust-status-node/status
random: rust-node/random
build: cargo build -p dora-record
path: ../../target/debug/dora-record
inputs:
message: rust-status-node/status random: rust-node/random

0 comments on commit 8c1412e

Please sign in to comment.