Add an executor subcommand to sdks/python/taskito/cli.py that loads the app with the existing _load_queue helper (cli.py:247) and attaches to a scheduler instead of running its own poller.
taskito executor --attach $TASKITO_ATTACH --app myapp:queue
Env equivalents shared with the other SDKs: TASKITO_ATTACH, TASKITO_ATTACH_TOKEN, TASKITO_SLOTS.
Reuse the execution loop in sdks/python/taskito/prefork/child.py — it already imports the app, initialises resources, and writes result frames; the transport is the only part that changes.
Done when an integration test runs the server plus one attached executor and asserts success, retry, cancel, and a clean drain on SIGTERM. Plan: tasks/executor-attach.md.
Add an
executorsubcommand tosdks/python/taskito/cli.pythat loads the app with the existing_load_queuehelper (cli.py:247) and attaches to a scheduler instead of running its own poller.taskito executor --attach $TASKITO_ATTACH --app myapp:queueEnv equivalents shared with the other SDKs:
TASKITO_ATTACH,TASKITO_ATTACH_TOKEN,TASKITO_SLOTS.Reuse the execution loop in
sdks/python/taskito/prefork/child.py— it already imports the app, initialises resources, and writes result frames; the transport is the only part that changes.Done when an integration test runs the server plus one attached executor and asserts success, retry, cancel, and a clean drain on SIGTERM. Plan:
tasks/executor-attach.md.