418 Commits (main)

Author SHA1 Message Date
  haixuanTao 0870f775ee Remove introduced typo in PR 2 years ago
  haixuanTao c311bc1230 Log which python is used 2 years ago
  haixuanTao 4462d99eb4 Add pythpn version to debug message 2 years ago
  haixuanTao c87bb1b283 Use python to execute python script 2 years ago
  haixuanTao adcfeaf3b8 Fix python path error using path searching for both `python3` and `python` 2 years ago
  Philipp Oppermann ad3f0482ac
Avoid alignment errors by aligning raw data on deseralization 2 years ago
  Philipp Oppermann 8cc5837cfa
Update `arrow` and `pyo3` dependencies to latest versions 2 years ago
  Philipp Oppermann 6140681ab9
Rename and reexport `Data` enums 2 years ago
  Philipp Oppermann bbb9b02a0d
Update clap to v0.4.3 2 years ago
  Philipp Oppermann 19f9cc7c90
Add support for arbitrary Arrow types in Python API 2 years ago
  haixuanTao 90c28de777 Fix clippy warnings about unnecessary `.clone()`, `.into()`, borrowing and let statement 2 years ago
  haixuanTao 0220d1ef65 Adding `data_type` to metadata for typing output 2 years ago
  haixuanTao 6b910ab619 Adding `arrow-schema` as dependency 2 years ago
  haixuanTao eb515c7755 Removing lifetime to the Metadata struct 2 years ago
  haixuanTao 107dd6b860 Use `read_line` instead of `next_line` and log full python traceback 2 years ago
  haixuanTao 4cbc9950ff Remove newline in the main loop as it is adding an additional line in stdout 2 years ago
  haixuanTao 423e569ceb Adding newline between lines for formatting 2 years ago
  Philipp Oppermann 4da34d82d9
Merge branch 'main' into event-timestamps 2 years ago
  Philipp Oppermann 5139c85a87
Use timestamps for coordinator messages and inter daemon events 2 years ago
  Philipp Oppermann 984ee364e4
Fill in timestamps when sending events from node to daemon 2 years ago
  Philipp Oppermann e0559b031e
Add HLC clock to daemon and to all event types 2 years ago
  Haixuan Xavier Tao 2e9108e894
Merge pull request #301 from dora-rs/pass-dataflow-to-nodes 2 years ago
  Philipp Oppermann 0bf31b750e
WIP: Add `uhlc` timestamps to all events and update HLC clocks 2 years ago
  Philipp Oppermann 8a439c3411
Pass dataflow descriptor to Rust nodes via API 2 years ago
  Philipp Oppermann 6ecbf4cfdc
Improve formatting of collected log messages 2 years ago
  Philipp Oppermann 57110fa9ca
Report node errors to coordinator on stop 2 years ago
  Philipp Oppermann aa6de7bb24
Don't break up multi-line log messages of nodes 2 years ago
  Philipp Oppermann 97bc9d0f92
Merge branch 'main' into heartbeat 2 years ago
  Philipp Oppermann 7499d43c06
Fix: Handle node spawn error like stop-before-subscribe 2 years ago
  Philipp Oppermann 893ca100ec
Improve subscribe error message when nodes failed before init 2 years ago
  Philipp Oppermann 5edfc394a6
Use monotonic `Instant` instead of `SystemTime` 2 years ago
  Philipp Oppermann 520fa352da
Merge branch 'main' into node-errors-before-init 2 years ago
  Philipp Oppermann f54b25c0d8
Merge pull request #277 from dora-rs/fix-tracing-error 2 years ago
  Philipp Oppermann 7d646509c2
Replace watchdog by asynchronous heartbeat messages 2 years ago
  Philipp Oppermann 026ddd915f
Fix: Only update dataflow status on exit events of pending nodes 2 years ago
  Philipp Oppermann ac0c521837
Fix: Only report init state to coordinator once 2 years ago
  Philipp Oppermann be92d9d43b
Handle coordinator synchronization message internally in `pending` submodule 2 years ago
  haixuanTao 68a690cd2e Improve error messages when nodes fails as they are no longer reported within stdout. 2 years ago
  haixuanTao 8740314124 Wait for logs to be logged before exiting daemon 2 years ago
  haixuanTao 664e8d48ba Minor refactoring 2 years ago
  haixuanTao 1caf7c7178 Make daemon not panic if logs are not written 2 years ago
  haixuanTao b8fbfbd4a1 Print log on std stdout/err if logging thread failed 2 years ago
  haixuanTao 5c98327655 Reply logs in a new thread in order to not block daemon when reading logs 2 years ago
  haixuanTao 7f82f32a98 Make logs not fail in the daemon 2 years ago
  haixuanTao 0854f9149a Make a centralised `log_path` function 2 years ago
  Philipp Oppermann 9217d848ee
Fix: Don't try to create two global tracing subscribers when using bundled runtime 2 years ago
  Philipp Oppermann e20699de3f
Handle node errors during initialization phase 2 years ago
  haixuanTao 5573e4b5c0 Pipe custom node stdout 2 years ago
  haixuanTao 29d7ed728e Refactor spawning of log thread to avoid deadlock 2 years ago
  haixuanTao 9707c1c66b Make sure that logs are been synced to disk before exiting 2 years ago