Philipp Oppermann
1b665b0c44
CLI: Add a hidden `connected-machines` command
This command is useful for testing examples with multiple daemons.
1 year ago
Philipp Oppermann
00df8f2936
Fix: Wait until dora daemon is connected to coordinator on `dora up`
It might take a short time until the daemon is connected to the coordinator after start-up. This could lead to issues when using `dora up` in a script because a subsequent `dora start` command might fail when the daemon is not connected at that point.
This commit fixes this issue by waiting until the coordinator confirms that a daemon is connected before returning from `dora up`.
1 year ago
haixuanTao
9f8bb2c0a5
Use u32 instead of usize for PID
1 year ago
haixuanTao
a631cafe52
Reply to stop msg immediately to coordinator
1 year ago
haixuanTao
e66b7ce67b
Adding long arg for grace duration and adding more grace duration within the CI
1 year ago
haixuanTao
b9f67a2855
Add grace duration and kill process
1 year ago
Philipp Oppermann
b3f652df8b
Use `resolver = 2` for in workspace in Rust template
Avoids a cargo warning.
1 year ago
Michael-J-Ward
ae9e19e57f
refactor: format error messages without allocating a string for each line
I added a test to confirm the output matches the old.
Fixes clippy warning clippy::format_collect
https://rust-lang.github.io/rust-clippy/master/index.html#/format_collect
1 year ago
Michael-J-Ward
3b59b026b4
lint: allow type-complexity for select signatures
1 year ago
Michael-J-Ward
dfe298eb1e
lint: fix clippy lints
1 year ago
Michael-J-Ward
431d72ce4c
refactor: rename coordinator listen port configuration to addr
1 year ago
Michael-J-Ward
a9bfafd7fc
refactor: use `addr` instead of `bind` to configure daemon listen address
1 year ago
Philipp Oppermann
01707fc14d
Fix: Use `peer_addr` of incoming daemon register request for listen socket
We are not interested in the local bind address of the daemon. Instead, we want to use the IP address under which the daemon is available from other machines.
This should also avoids the issue that connecting to 0.0.0.0 is not possible on Windows (we want to use 0.0.0.0 as default bind address).
1 year ago
Philipp Oppermann
6115ddbb4d
Revert "update dora_coordinator::start to return bound addr instead of just the port"
This reverts commit 1ba763cd67 .
1 year ago
Philipp Oppermann
e76f497939
Revert "revert to daemons listening to 127.0.0.1 by default"
This reverts commit 4af82a4833 .
1 year ago
Michael-J-Ward
4af82a4833
revert to daemons listening to 127.0.0.1 by default
clients can not connect to `0.0.0.0` on windows.
1 year ago
Michael-J-Ward
1ba763cd67
update dora_coordinator::start to return bound addr instead of just the port
1 year ago
Philipp Oppermann
279530e21d
Delay watchdog disconnect to 30 seconds
1 year ago
Philipp Oppermann
58eac29024
Increase log level of 'disconnecting daemons' message to `error`
1 year ago
Michael-J-Ward
3a6323ff0c
feat: add bind configuration for coordination daemon
Ref: #459
1 year ago
Michael-J-Ward
f6590224b4
feat: add bind configuration for the inter_daemon listener
Ref: #459
1 year ago
haixuanTao
c6948c1644
Only use conda if conda is present
1 year ago
haixuanTao
15af539729
Adding customizing `conda_env` within Python operator
This commit makes it possible to specify the conda env that we want to use in
a specific operator.
```yaml
- id: robot
operator:
python:
source: ../operators/robot.py
conda_env: robomaster
```
This will call:
```bash
conda run -n robomaster python -c "import dora; dora.start_runtime()"
```
1 year ago
Philipp Oppermann
14bb4fbfb7
Merge pull request #429 from dora-rs/out_dir
Send runs artefacts into a dedicated `out` folder
1 year ago
haixuanTao
f0db125499
Use `Uuid::v7` to have chronological Uuid
1 year ago
haixuanTao
99026243ba
Push logs into `out/<dataflow_id>/log_<node_id>.txt` instead of `temp_dir` to make it easier to check
1 year ago
haixuanTao
b32a7e4924
Make `send_stdout_as` fail if there is more than one entry for a runtime node
1 year ago
haixuanTao
12af6a1007
Removing unused imports
1 year ago
haixuanTao
aa81da0142
Add possibility to send stdout for operators and add warnings when there is multiple operators
1 year ago
Philipp Oppermann
daa694ad98
Add new `send_stdout_as` key for capturing stdout of custom nodes
2 years ago
haixuanTao
91bd7daf50
Adding log event
2 years ago
haixuanTao
629a218ddb
`copy_array_into_sample` do not need to return a result
2 years ago
Philipp Oppermann
e8b87f0338
Merge branch 'main' into c++-ros2-bridge
1 year ago
Philipp Oppermann
2eeb40b1ff
Fix operator API: Box optional error string since `Option<String>` is not FFI-safe
1 year ago
Haixuan Xavier Tao
d0df0f67a8
Merge pull request #424 from dora-rs/update-bat
1 year ago
Philipp Oppermann
fecb58be60
Update `bat` dependency to v0.24
1 year ago
haixuanTao
4ca53258ad
Move opentelemetry implementation to `dora metrics`
2 years ago
haixuanTao
0725620eab
Simplyfing the metrics functionality by using meter provider instead of
the global meter.
2 years ago
haixuanTao
0985bd4f9b
Make first positional argument optional
Bump 0.3.2-rc2
2 years ago
haixuanTao
573a7bc425
Make it possible to check the logs without passing uuid
This commit make it possible to check the logs as follows:
```bash
dora logs object_detection
```
If more than one dataflow is running, we will inquire for which dataflow to use.
2 years ago
haixuanTao
4085ebc46b
Make PrimitiveArray only serialize one element at a time
2 years ago
haixuanTao
b79172c9bc
Removing `coordinator_addr` for `run_dataflow` command
2 years ago
Philipp Oppermann
cb69a033f0
Wait until `DestroyResult` is sent before exiting dora-daemon
Tokio background tasks are canceled when the program exits, so we need some additional synchronization to ensure that the `DestroyResult` is actually sent out.
2 years ago
Philipp Oppermann
249b2925f8
Revert "Respond to coordinator destroy immediately to avoid end of file error"
This reverts commit 5c16c59b6f .
2 years ago
haixuanTao
5c16c59b6f
Respond to coordinator destroy immediately to avoid end of file error
2 years ago
haixuanTao
28be4a6663
Fix example by using the right daemon command
2 years ago
haixuanTao
054ae5afcc
Fix multiple daemon example
2 years ago
haixuanTao
ddf94f7094
Adding ctrlc back to their individual repo
2 years ago
haixuanTao
88902cb97b
Make tracing available for node in the runtime
2 years ago
haixuanTao
0568656ef0
Remove unused dependencies for faster compile time
2 years ago