feat: Realtime input streams for bidirectional task communication#3145

Closed

ericallam wants to merge 12 commits into

mainfrom

claude/temporal-signals-versioning-xzlHf

Commits on Feb 27, 2026

feat: add streams.input() for inbound realtime data to running tasks

claude
authored and
ericallam
committed
refactor: connect input stream tail lazily from listener side

claude
authored and
ericallam
committed
fix: gate input stream tail connection on v2 realtime streams

claude
authored and
ericallam
committed
fix: throw error when input streams are used without v2 realtime streams

claude
authored and
ericallam
committed
docs: add input streams documentation to realtime guides

claude
authored and
ericallam
committed
docs: add API/SDK design proposal for temporal signals versioning

claude
authored and
ericallam
committed
chore: remove temporal signals versioning design doc

claude
authored and
ericallam
committed
docs: add SDK design proposal for input stream .wait() method

claude
authored and
ericallam
committed
input stream waitpoints and tests in the hello world reference project
ericallam
committed
No more input stream multiplexing, no naming collision risk, removed unnecessary waitpoint added columns.
ericallam
committed
Better span experience, show input streams on dashboard, cleanup the data format
ericallam
committed
adopt s2-lite, upgrade s2 package with support
ericallam
committed