108 Commits (tweak-queue-sizes)

Author SHA1 Message Date
  Philipp Oppermann 7232a31b57
Send `InputClosed` events to operators too 2 years ago
  Philipp Oppermann 9e4f01318a
Fix: Move `InputBuffer` break condition to end of loop 2 years ago
  Philipp Oppermann 598ece765e
Don't panic in runtime when operator panics 2 years ago
  Philipp Oppermann ea537d45f6
Remove resolved TODO 2 years ago
  Philipp Oppermann a84f91c572
Fix: Don't keep on polling incoming event channel after it's closed 2 years ago
  Philipp Oppermann a35850cb07
Drop oldest operator inputs when queue becomes too full 2 years ago
  Philipp Oppermann 0f29d26fe8
Drop oldest operator inputs when queue becomes too full 2 years ago
  Philipp Oppermann a9203e0274
Add intermediate operator channel buffer to avoid blocking runtime 2 years ago
  Philipp Oppermann de786ef101
Fix some warnings in runtime 2 years ago
  Philipp Oppermann cdc0be1206
Rename `FfiEvent` to `RawEvent` 2 years ago
  Philipp Oppermann 62319f1ec1
Add support for Rust operators again 2 years ago
  Philipp Oppermann d334c6f243
Make `daemon` module of Rust node API private and reexport symbols 2 years ago
  Philipp Oppermann 83c8ecf3e9
Change Python operator API: `on_event` instead of `on_input` 2 years ago
  Philipp Oppermann 1e07a73a64
Merge branch 'main' into unify-nodes-and-operators 2 years ago
  Philipp Oppermann 1553a198ef
Re-export dora-message from dora-core 2 years ago
  Philipp Oppermann 8dc184a7e8
Improve a log message 2 years ago
  Philipp Oppermann 5e4f1b2519
Clean up 2 years ago
  Philipp Oppermann ea2c39a26c
Remove unused runtime dependencies 2 years ago
  Philipp Oppermann 67976d2c41
Add some Debug derives 2 years ago
  Philipp Oppermann 18a908c579
Close operator event channel after last input is closed 3 years ago
  Philipp Oppermann c27d7d1a34
Propagate panics of runtime main task 3 years ago
  Philipp Oppermann 6980636686
Update futures-concurrency to v7.1 3 years ago
  Philipp Oppermann 0d1bbc8eb5
Fix: actually send input to runtime instead of dropping future 3 years ago
  dependabot[bot] b74a524031
Bump tokio from 1.23.1 to 1.24.2 3 years ago
  Philipp Oppermann ea136adc2e
Fix: Run Python operator in main thread 3 years ago
  Philipp Oppermann 2e67362c15
Fix: Python operator spawning is blocking, so do it in a separate thread 3 years ago
  Philipp Oppermann 772fc41d93
Slight improvements to log messages 3 years ago
  Philipp Oppermann cac527a382
Add support for spawning runtime nodes with operators 3 years ago
  Philipp Oppermann 27d74a7a71
Resolve some todos 3 years ago
  Philipp Oppermann 4bd235afd7
Close event channels after sending Stop 3 years ago
  Philipp Oppermann 00b863fdc9
Fix some warnings and remove some unused code 3 years ago
  Philipp Oppermann 6eb9b46637
Close outputs of operators when they stop 3 years ago
  Philipp Oppermann d6470e75a3
Don't use blocking output send function in runtime loop 3 years ago
  Philipp Oppermann 492339a687
WIP: Start porting `dora-runtime` to `dora-daemon` 3 years ago
  haixuanTao a841577e10 add documentation of scoped unsage `GILPool` 3 years ago
  haixuanTao d45f9373fd Use `py.new_pool()` to bound pyo3 variable 3 years ago
  haixuanTao 71078bd9f2 Force removal of Pyo3 Object to avoid memory leak 3 years ago
  dependabot[bot] ae161e644c
Bump tokio from 1.21.2 to 1.23.1 3 years ago
  Philipp Oppermann df5dcfb342
Merge branch 'main' into unify-nodes-and-operators 3 years ago
  Philipp Oppermann 433b7b4ed7
Merge branch 'main' into unify-nodes-and-operators 3 years ago
  Philipp Oppermann ce4fd8b027
Set dora subcrate dependencies as workspace dependencies 3 years ago
  Philipp Oppermann d8260d5d2c
Inherit package version from workspace root 3 years ago
  haixuanTao b15d25b9a3 Fix clippy warnings 3 years ago
  haixuanTao 9a0b303e98 Replace all versions to `v0.1.1` 3 years ago
  haixuanTao 32e11f538c Remove `stop_thread` loop after a `StopAll` 3 years ago
  haixuanTao 294990e307 Make `stop_thread` not borrow `communication` for static 3 years ago
  Philipp Oppermann 1d2d71b15a
Comment out uses of communication layer in coordinator for now 3 years ago
  haixuanTao 9ec9d22620 wait for stop thread to finish before stopping runtime 3 years ago
  haixuanTao 9f0a0e6957 Fix GIL race condition 3 years ago
  haixuanTao 992b8251c2 DRAFT: Fixing Python linking error 3 years ago