Skip to content

Pull requests: hydro-project/hydro

New pull request New
26 Open 1,954 Closed
26 Open 1,954 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Assigned to nobody Loading
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

refactor(dfir_rs): remove SubgraphId, SubgraphTag, LoopId, LoopTag, simplify StateLifespan
#2812 opened Apr 24, 2026 by MingweiSamuel Member • Draft
1
refactor(dfir_rs,dfir_lang): remove SubgraphId argument from schedule_subgraph, remove current_subgraph
#2811 opened Apr 24, 2026 by MingweiSamuel Member • Draft
1
refactor(dfir_rs): use slotmap SecondaryMap for metrics
#2810 opened Apr 24, 2026 by MingweiSamuel Member • Draft
7
feat(hydro_lang): make IR types serializable via serde
#2808 opened Apr 24, 2026 by jhellerstein Contributor Loading…
1
@shadaj
10
feat(hydro_lang): add broadcast_closed for fixed-membership clusters
#2807 opened Apr 24, 2026 by jhellerstein Contributor Loading…
1
@shadaj @MingweiSamuel
8
Kafka example
#2805 opened Apr 23, 2026 by akainth015 • Draft
fix(dfir_rs): defer _counter task spawning via Context::request_task buffer
#2804 opened Apr 23, 2026 by MingweiSamuel Member Loading…
4
refactor(dfir_lang): operators capture local state instead of using the state API [ci-bench]
#2801 opened Apr 23, 2026 by MingweiSamuel Member • Draft
2
refactor(dfir_lang): remove unused topo_sort_scc and scc_kosaraju
#2800 opened Apr 23, 2026 by MingweiSamuel Member Loading…
3
refactor(dfir_lang): double-buffer defer_tick handoffs, remove intermediate subgraphs [ci-bench]
#2798 opened Apr 23, 2026 by MingweiSamuel Member Loading…
9
feat(hydro_lang): track cross-cluster-member consistency in the type system
#2796 opened Apr 23, 2026 by shadaj Member • Draft
1
feat(hydro_lang): smart join that preserves ordering when right side is bounded
#2778 opened Apr 22, 2026 by jhellerstein Contributor Loading…
1
28
feat(hydro_test): add example of AWS + SQS support
#2746 opened Apr 15, 2026 by MingweiSamuel Member Loading…
32
chore: update nightly snapshots
#2733 opened Apr 14, 2026 by hydro-project-bot Bot Loading…
1
fix(dfir_pipes): resolve_futures poll_ready blocking multiple pending futures, fix #2662
#2663 opened Mar 18, 2026 by MingweiSamuel Member • Draft
4
refactor(sinktools): use pin_project in LazySinkSource
#2579 opened Feb 13, 2026 by MingweiSamuel Member • Draft
3
refactor(sinktools): LazySinkSource cleanup waker handling, use StreamExt::split, improve unit tests, fix #2336
#2556 opened Feb 6, 2026 by MingweiSamuel Member Loading…
1
14
fix(dfir_lang): Add FusedStream requirement to source_stream
#2552 opened Feb 6, 2026 by Copilot AI • Draft
1
@MingweiSamuel
2
fix(hydro_lang): initialize tracing in deployed child processes
#2533 opened Feb 3, 2026 by mkayuri Loading…
3
fix(hydro_lang): add forwardref cycle detection, fix #2080
#2399 opened Dec 31, 2025 by Shasha-17 Loading…
1
feat(hydro_lang): use mimalloc when compiling for an external host
#2268 opened Nov 10, 2025 by shadaj Member • Draft
3
perf(benches): test mock tracing performance [ci-bench]
#2208 opened Oct 22, 2025 by MingweiSamuel Member • Draft
feat(hydro_test): websocket chat demo
#2130 opened Sep 18, 2025 by shadaj Member • Draft
1
feat(hydro_test): websocket protocol demo
#2128 opened Sep 18, 2025 by shadaj Member • Draft
1
docs(rfc): stream alignment
#2027 opened Aug 21, 2025 by shadaj Member Loading…
15
ProTip! Updated in the last three days: updated:>2026-04-22.