Skip to content

scheduler: route task cancellation through callback hook#19

Merged
phillipleblanc merged 1 commit into
spiceai-51from
phillip/cancel-tasks-control-stream
Feb 12, 2026
Merged

scheduler: route task cancellation through callback hook#19
phillipleblanc merged 1 commit into
spiceai-51from
phillip/cancel-tasks-control-stream

Conversation

@phillipleblanc
Copy link
Copy Markdown

@phillipleblanc phillipleblanc commented Feb 12, 2026

Summary

  • add a scheduler config callback type (OnCancelTasksFn) for cancelling running tasks per executor
  • update ExecutorManager::cancel_running_tasks to invoke the callback when configured, with fallback to existing gRPC cancellation behavior
  • add a unit test to verify cancellation requests are grouped by executor and dispatched via the callback

Task cancellation was previously only supported through the ExecutorGrpc method, this allows the hosting application more flexibility when deciding how to cancel tasks.

@phillipleblanc phillipleblanc merged commit 9298d44 into spiceai-51 Feb 12, 2026
32 checks passed
@phillipleblanc phillipleblanc deleted the phillip/cancel-tasks-control-stream branch February 12, 2026 23:23
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants