Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Propose queue changeTaskRunPriority #190

Open
wants to merge 6 commits into
base: main
Choose a base branch
from
Open
Show file tree
Hide file tree
Changes from 3 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -68,3 +68,4 @@ See [mechanics](mechanics.md) for more detail.
| RFC#180 | [Github cancel previous tasks](rfcs/0180-Github-cancel-previous-tasks.md) |
| RFC#182 | [Allow remote references to .taskcluster.yml files processed by Taskcluster-GitHub](rfcs/0182-taskcluster-yml-remote-references.md) |
| RFC#189 | [Batch APIs for task definition, status and index path](rfcs/0189-batch-task-apis.md) |
| RFC#190 | [Queue change task / task group priority](rfcs/0190-queue-change-task-run-priority.md) |
74 changes: 74 additions & 0 deletions rfcs/0190-queue-change-task-run-priority.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,74 @@
# RFC 0190 - Queue change task / task group priority
* Comments: [#0190](https://github.com/taskcluster/taskcluster-rfcs/pull/190)
* Proposed by: @lotas

## Summary

Since we refactored queue internals it became possible to see what tasks are pending for a particular
worker pool / task queue.

This RFC proposes new API method that would allow to change the priority of the existing task run / task group.

## Motivation
lotas marked this conversation as resolved.
Show resolved Hide resolved

There might be several use-cases when some worker pool has a lot of pending tasks and there is a need
to move some more important tasks to the top of the waiting list, or also move down less important ones.

Instead of cancelling some existing tasks we can change task run priorities.

Use-case examples:

* We have a high-priority patch running tasks on Try. We want to bump the priority of all tasks in this task group
* We have a chemspill release or high priority nightly to get out. We want to bump the priority of all tasks in one or more groups
* We are waiting for a specific task in a low resource pool (eg: mac hardware). We want to bump the priority of that specific task
* There are several tasks with the same highest priority and one of them is more important. We want to lower the priority of the less important task

## Details

Queue service will expose new methods:

* `queue.changeTaskPriority(taskId, newPriority)`
* `queue.changeTaskGroupPriority(taskGroupId, newPriority)`

New priority would be stored along the task definition for a given task or all tasks within the task group.

The process to change single task will be as follows:

* new task priority will be stored in the database as `task.priority_override` column
* if task was scheduled already, its priority in the `queue_pending_tasks` table will be updated
lotas marked this conversation as resolved.
Show resolved Hide resolved
* if the tasks run fails and new one is created, it will check if `task.priority_override` is set and use it instead of the original priority

The process to change the whole task group will be as follows:

* all tasks in the task group will be updated to store the new priority in the `task.priority_override` column
* all currently scheduled tasks would be attempted to be updated in the `queue_pending_tasks` table
* all unscheduled tasks and tasks that will be restarted will use the new priority

### New scopes

This will also require introduction of the new scopes (anyOf):

* `queue:change-task-priority-in-queue:<taskQueueId>`
* `queue:change-task-priority:<taskId>`
* `queue:lower-task-priority:<taskId>` to only allow lowering the priority
* `queue:raise-task-priority:<taskId>` to only allow raising the priority
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

It's hard to be certain if we'll use them, but I like this break out of raising/lowering - nice addition!

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

now that I think about it.. maybe it's too dangerous. If someone can lower the priority of a task that means that high-priority tasks might be de-prioritized.

@jcristau suggested to include existing and new priority in the scope as well, maybe we should do that instead

queue:change-task-priority:<newPriority>:<existingPriority>:<taskId> // to allow easier wildcard scopes
queue:change-task-group-priority:<newPriority>/<taskGroupId>

wdyt?

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I think either are fine, but it may affect who we grant these scopes to depending on the implementation.


And for task group:

* `queue:change-task-group-priority:<schedulerId>/<taskGroupId>` (for consistency with existing task group scopes)
* `queue:lower-task-group-priority:<taskGroupId>` to only allow lowering the priority
* `queue:raise-task-group-priority:<taskGroupId>` to only allow raising the priority

### Priority calculation

Current order for picking up tasks is based on the task priority and insertion time (FIFO).
This RFC proposes to change the priority only, and leave the insertion time as is.

### Other considerations

To insure that Chain of Trust validation is not affected, we aim to keep the original task definition
lotas marked this conversation as resolved.
Show resolved Hide resolved
and store the new priority in a separate column.
lotas marked this conversation as resolved.
Show resolved Hide resolved

## Implementation

_pending_
1 change: 1 addition & 0 deletions rfcs/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -56,3 +56,4 @@
| RFC#180 | [Github cancel previous tasks](0180-Github-cancel-previous-tasks.md) |
| RFC#182 | [Allow remote references to .taskcluster.yml files processed by Taskcluster-GitHub](0182-taskcluster-yml-remote-references.md) |
| RFC#189 | [Batch APIs for task definition, status and index path](0189-batch-task-apis.md) |
| RFC#190 | [Queue change task / task group priority](0190-queue-change-task-run-priority.md) |