feat(sdks): taskito executor subcommand for Python, Node and Java - #595

Merged

kartikeya-27 merged 46 commits into

ByteVeda:masterfrom

stromanni:feat/546-executor-attach-sdks

Aug 1, 2026

Commits on Aug 1, 2026

feat(core): invert the job and result frame mappings
stromanni
committed
15d8fe3
feat(core): executor-side attach client
stromanni
committed
2695ca5
feat(core): shared attach-address dialer
stromanni
committed
f7bdfb3
feat(core): shared cancel source for dispatchers
stromanni
committed
25fb04d
feat(python): executor binding over the prefork pool
stromanni
committed
ee8388c
feat(python): taskito executor subcommand
stromanni
committed
0a76da4
test(python): cover the executor attach end to end
stromanni
committed
ad05c0f
feat(core): observable executor session
stromanni
committed
de17b86
refactor(node): extract the task callback
stromanni
committed
7601ce3
refactor(node): share the CLI app loader
stromanni
committed
fc4ee55
feat(node): executor binding over the node dispatcher
stromanni
committed
e7da425
feat(node): runExecutor on the queue
stromanni
committed
8db36f2
feat(node): taskito executor subcommand
stromanni
committed
17dbfee
test(node): cover the executor attach end to end
stromanni
committed
f7c45fe
fix(core): end the session on a local drain
stromanni
committed
af1594f
feat(java): emit discoverable handler providers
stromanni
committed
fecda3b
feat(java): executor binding over the java dispatcher
stromanni
committed
b00503d
feat(java): Executor over an attached scheduler
stromanni
committed
ed0b6c0
feat(java): executor subcommand
stromanni
committed
c7b286f
test(java): cover the executor attach end to end
stromanni
committed
4884feb
feat(python): executor opens no storage
stromanni
committed
7009304
test(python): cover an executor with no database
stromanni
committed
3b2eafc
feat(node): deliver frame cancels to the handler
stromanni
committed
f11f5ac
feat(node): executor opens no storage
stromanni
committed
d8956b2
test(node): cover an executor with no database
stromanni
committed
4916a2a
fix(core): resolve the cancel module doc link
stromanni
committed
52a8735
test(python): type the attach tests' stderr reads
stromanni
committed
39126be
fix(core): dial every resolved scheduler address
stromanni
committed
d430e94
refactor(core): move the worker tests to tests/rust
stromanni
committed
9112610
fix(core): drain locally before announcing to the peer
stromanni
committed
1668ed8
fix(core): bound shutdown when a job never returns
stromanni
committed
607c483
fix(java): do not generate a provider for a nested handler
stromanni
committed
351aa51
fix(java): drop the drain hook on the normal exit path
stromanni
committed
40db7b6
fix(java): validate --slots and report through the spec
stromanni
committed
f605ede
fix(java): release the lock before the session wait
stromanni
committed
1934391
fix(java): close the handle if post-attach setup throws
stromanni
committed
6892390
fix(node): handle a rejected stop in the signal path
stromanni
committed
fec80be
fix(node): release the attach if start-up throws
stromanni
committed
528573d
feat(node): shutdown stops executors too
stromanni
committed
0a3c6b2
test(node): discard the server's output
stromanni
committed
eb452aa
style(java): wrap the service-loadable guard for spotless
stromanni
committed
fab6f68
docs(core): note the job fields a dispatch frame drops
stromanni
committed
bcb21c9
docs(python): state what can delay executor stop()
stromanni
committed
abdd44a
docs(java): describe the generated Provider correctly
stromanni
committed
6dad121
fix(java): treat a blank attach token as absent
stromanni
committed
9f0aea2
test(python): poll for the attach instead of sleeping
stromanni
committed
42be90b