dora-rs/dora - dora - 开源协同云脑生态支撑系统

Commit Graph

Author	SHA1	Message	Date
haixuanTao	2bfd069ae5	Fix documentation link	3 years ago
haixuanTao	b91b6db3f4	Remove legacy python example	3 years ago
haixuanTao	b1c25e19e7	Make op queue full error a warning	3 years ago
Philipp Oppermann	b9ce8f0e4b	Fix: remove moved examples from coordinator manifest	3 years ago
Philipp Oppermann	8e21a990d0	Create a Rust dataflow example The example shows how to use the dora node and operator APIs.	3 years ago
Philipp Oppermann	1475af4711	Reduce log level for zenoh subcrates Keep the warning messages for now.	3 years ago
Philipp Oppermann	74fe6700b4	Run cargo fmt	3 years ago
Philipp Oppermann	4b9807735f	Merge branch 'main' into c-node-api	3 years ago
Philipp Oppermann	a6781fd4a9	Canoncicalize node path before launching it	3 years ago
Philipp Oppermann	bad8d30a5f	Split coordinator binary into lib.rs and main.rs Allows using the `run` function from tests and examples.	3 years ago
Philipp Oppermann	7c801fba2f	Merge branch 'main' into stop-operation	3 years ago
Philipp Oppermann	7cc3b1c5c2	Merge pull request #59 from dora-rs/fix-clippy Resolve clippy warnings	3 years ago
Philipp Oppermann	dbf189e239	Resolve clippy warnings	3 years ago
Philipp Oppermann	128922ac65	Remove error status for Python in favor of native Python errors	3 years ago
haixuanTao	bf2b9fceb3	impl `traceback` that get traceback from `PyErr`	3 years ago
haixuanTao	f016158e6d	Recover the `traceback` from `PyErr` and use `PyBytes` as input Recovering the traceback allow to see on which line did Python failed. Using Pybytes as input make the python input type `bytes` instead of a List of `u8`.	3 years ago
Philipp Oppermann	f182330c5e	Increase sink timeout to 5 seconds We're now launching the nodes/operators using `cargo run`, which can lead to a bit of delay. We don't want to trigger the timeout in this case.	3 years ago
Philipp Oppermann	f1a8da7ee1	Fix: Don't wait for dora timer tasks in coordinator Instead, exit as soon as all nodes and operators are done. The timer tasks will never finish.	3 years ago
Philipp Oppermann	825e9a8d7b	Allow operators to stop themselves through a special return value Useful for source operators that take timers as inputs. Without an explicit stop instructions, they would always run forever.	3 years ago
Philipp Oppermann	41afaed2c1	Add some more log messages	3 years ago
Philipp Oppermann	7158ff2d38	Send `InputsStopped` event only once, after all inputs are closed Ensures that the event is only sent after all input straems are exhausted. This avoids a potential race when there are multiples inputs.	3 years ago
Philipp Oppermann	e677adbd58	Keep operators that use dora timers as inputs running indefinitely The dora timers produce values forever. We only want to stop operators when all their input streams are closed.	3 years ago
Philipp Oppermann	ed59e69eca	Fix coordinator run instructions in README	3 years ago
Philipp Oppermann	9b711d3964	Fix paths in `mini-dataflow.yml` example	3 years ago
Philipp Oppermann	20501ca461	Send dora timer messages from coordinator	3 years ago
Philipp Oppermann	acd0f6193f	Adjust libraries and binaries for new `InputMapping` format	3 years ago
haixuanTao	e661324253	change test graph input name `time` to` string`	3 years ago
haixuanTao	6b2b082e71	Renaming `PyDoraNode` to `Node`	3 years ago
haixuanTao	79da342b62	Adding test graph for python node	3 years ago
haixuanTao	c6b671b4ee	moving `node` examples into a specific folder	3 years ago
Philipp Oppermann	2750ea59b1	Rename config fields to 'definition'	3 years ago
Philipp Oppermann	45378870ad	Generalize support for single-operator nodes, independent of their type	3 years ago
Philipp Oppermann	bc56b5947d	Implement alias syntax for runtime nodes with single python operator	3 years ago
haixuanTao	251fe6b20f	Replaced `dora-common` with `dora-core`	3 years ago
haixuanTao	28a902d83a	Moving folders in correspondance with #41 Simply moving crate to mirror our discussion without touching at names	3 years ago

35 Commits (code-comments)