search

dora-rs / dora

DORA (Dataflow-Oriented Robotic Architecture) is middleware designed to streamline and simplify the creation of AI-based robotic applications. It offers low latency, composable, and distributed dataflow capabilities. Applications are modeled as directed graphs, also referred to as pipelines.
https://dora-rs.ai
Apache License 2.0
1.5k stars 79 forks source link

Convert rust example to node #494

Closed Michael-J-Ward closed 5 months ago

Michael-J-Ward commented 5 months ago

Ref #474

1st commit is a minimalist conversion, tried to keep the behavior the same.

2nd commit removes some extra dependencies.

Note

The end behavior does appear different. On main, I will get ~10 to ~30 messages about dropped inputs, and I will only get 100 - num_dropped for operator received random value

2024-04-30T14:21:36.529492Z DEBUG dora_daemon::node_communication: dropped 1 inputs because event queue was too full
    at binaries/daemon/src/node_communication/mod.rs:328

With this conversion to the node api, i get no messages about dropped inputs and 100 operated received random value.

Ran with:

RUST_LOG=debug cargo run --example rust-dataflow
Michael-J-Ward commented 5 months ago

NOTE: I do not think that last commit fixed the CI failure for https://github.com/dora-rs/dora/pull/494/commits/5f873844c67af96697ee924a87b4a50ec609a6c0.

I suspected the failure was spurious, so I added the last commit to trigger a second run.

phil-opp commented 5 months ago

Thanks!