13 Commits

Include renames

Author	SHA1	Message	Date
BlackouttaandGitHub	736880e046	feat: support configurable redis key prefix (#35139)	2026-04-14 09:31:41 +00:00
3 people	d573fc0e65	refactor: replace bare dict with dict[str, Any] in VDB providers and libs (#35123) ... Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>	2026-04-14 03:02:29 +00:00
QuantumGhostandGitHub	1789988be7	fix(api): fix concurrency issues in StreamsBroadcastChannel (#34061)	2026-03-25 15:47:31 +08:00
QuantumGhostandGitHub	eef13853b2	fix(api): StreamsBroadcastChannel start reading messages from the end (#34030) ... The current frontend implementation closes the connection once `workflow_paused` SSE event is received and establish a new connection to subscribe new events. The implementation of `StreamsBroadcastChannel` sets initial `_last_id` to `0-0`, consumes streams from start and send `workflow_paused` event created before pauses to frontend, causing excessive connections being established. This PR fixes the issue by setting initial id to `$`, which means only new messages are received by the subscription.	2026-03-25 10:21:57 +08:00
wangxiaoleiandGitHub	2f4c740d46	feat: support redis xstream (#32586)	2026-03-04 13:18:55 +08:00
3 people	704ee40caa	fix(api): excessive high CPU usage caused by RedisClientWrapper (#32212) ... Co-authored-by: gemini-code-assist[bot] <176961590+gemini-code-assist[bot]@users.noreply.github.com>	2026-02-11 09:49:29 +08:00
6 people	a1fc280102	feat: Human Input Node (#32060) ... The frontend and backend implementation for the human input node. Co-authored-by: twwu <[email protected]> Co-authored-by: JzoNg <[email protected]> Co-authored-by: yyh <[email protected]> Co-authored-by: zhsama <[email protected]>	2026-02-09 14:57:23 +08:00
3 people	90fe9abab7	revert: revert human input relevant code (#31766) ... Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>	2026-01-30 19:18:49 +08:00
10 people	03e3acfc71	feat(api): Human Input Node (backend part) (#31646) ... The backend part of the human in the loop (HITL) feature and relevant architecture / workflow engine changes. Signed-off-by: yihong0618 <[email protected]> Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com> Co-authored-by: -LAN- <[email protected]> Co-authored-by: 盐粒 Yanli <[email protected]> Co-authored-by: CrabSAMA <[email protected]> Co-authored-by: Stephen Zhou <[email protected]> Co-authored-by: Copilot <[email protected]> Co-authored-by: yihong <[email protected]> Co-authored-by: Joel <[email protected]>	2026-01-30 10:18:49 +08:00
6 people	4f0fb6df2b	chore: use from __future__ import annotations (#30254) ... Co-authored-by: Dev <[email protected]> Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com> Co-authored-by: Asuka Minato <[email protected]> Co-authored-by: crazywoola <[email protected]>	2026-01-06 23:57:20 +09:00
4 people	ea320ce055	feat: add comprehensive unit tests for dataset service creation methods (#28522) ... Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com> Co-authored-by: gemini-code-assist[bot] <176961590+gemini-code-assist[bot]@users.noreply.github.com>	2025-11-22 13:38:35 +08:00
wangxiaoleiandGitHub	cad2991946	feat: support redis 7.0 shared pub and sub (#28333)	2025-11-21 10:33:52 +08:00
5 people	b9bc48d8dd	feat(api): Introduce Broadcast Channel (#27835) ... This PR introduces a `BroadcastChannel` abstraction with broadcasting and at-most once delivery semantics, serving as the communication component between celery worker and API server. It also includes a reference implementation backed by Redis PubSub. Co-authored-by: gemini-code-assist[bot] <176961590+gemini-code-assist[bot]@users.noreply.github.com> Co-authored-by: Copilot <[email protected]> Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>	2025-11-10 17:23:21 +08:00