erdos
erdos copied to clipboard
erdos-project
Dataflow system for building self-driving car and robotics applications.
Hi, thanks for your great work. I may need some help. I tried to use the deadline control in one operator. I followed the full_pipeline example: implement setup func for...
Tests fail because the ERDOS node tries and fails to connect to the rosmaster.
When an operator is under high load (i.e. messages are coming in at a very high rate), events are only inserted into the lattice and not removed/processed until the rate...
On Python 3.8+, ERDOS should use [`multiprocessing.shared_memory`](https://docs.python.org/3.8/library/multiprocessing.shared_memory.html) for nodes on the same machine to avoid serialization overhead.
To use ERDOS for a simple dataflow, users currently need to do the following: ```python use erdos::{ self, dataflow::{ message::*, operators::{JoinOperator, MapOperator}, stream::{ExtractStream, IngestStream, WriteStreamT}, Operator, OperatorConfig, ReadStream, WriteStream, },...
Some imports are duplicates, e.g. `erdos::dataflow::operators::Operator` and `erdos::dataflow::Operator`. Only 1 path per object is simpler (this likely will impact #110).
Currently, access to state isn't locked. When using the TimeVersionedState, we could introduce unsafe accesses due to concurrency if a watermark callback for time t and a data callback for...
The master prints an error when the`test_input_receiver_join` is run, but the test still succeeds and does not fail. ### Example Run the following command: `cargo test test_input_receiver_join -- --nocapture`. The...
Currently the Rust tests aren't well-organized. They should be refactored for clarity and logical organization (`tests/inter_thread_tests.rs` is especially in need of some attention).
Metadata
Owner
Metadata
Dataflow system for building self-driving car and robotics applications.