haixuanTao
|
2bfd069ae5
|
Fix documentation link
|
3 years ago |
haixuanTao
|
b91b6db3f4
|
Remove legacy python example
|
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
|
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
|
dbf189e239
|
Resolve clippy warnings
|
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
|
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
|
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 |