Skip to content

feat: add provisioner daemon and jobs endpoints and commands #15940

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.

Sign up for GitHub

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

Closed
wants to merge 21 commits into from
Closed

feat: add provisioner daemon and jobs endpoints and commands #15940

Changes from 1 commit
Commits
Show all changes
21 commits
Select commit Hold shift + click to select a range
650cbaf
feat: add provisioners and jobs endspoints and CLI commands
mafredri Dec 19, 2024
449df5d
wip
mafredri Dec 19, 2024
fa261b1
key
mafredri Dec 19, 2024
c5a0429
golden
mafredri Dec 19, 2024
b138faf
name
mafredri Dec 19, 2024
a0af6eb
gen
mafredri Dec 19, 2024
8975d41
test
mafredri Dec 20, 2024
96a278e
dbmem
mafredri Dec 20, 2024
e9b8725
typo
mafredri Dec 20, 2024
c5211ef
fix migrations
mafredri Dec 20, 2024
c6e1cc6
cleanup
mafredri Dec 20, 2024
9e64cdd
improve tests and dbmem
mafredri Dec 20, 2024
8fd1a6a
Update cli/provisionerjobs.go
mafredri Dec 20, 2024
b57bc8c
lint
mafredri Dec 20, 2024
32fde66
remove unused
mafredri Dec 20, 2024
38116d7
gen, remove unused
mafredri Dec 20, 2024
e7ac032
slice.ToStringEnums
mafredri Dec 20, 2024
f6c2a3f
lint & gen
mafredri Dec 22, 2024
876bd80
dbmem/golden
mafredri Dec 31, 2024
0788d56
revert
mafredri Dec 31, 2024
24d49da
undo rename
mafredri Dec 31, 2024
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
Prev Previous commit
Next Next commit
cleanup
  • Loading branch information
@mafredri
mafredri committed Jan 2, 2025
commit c6e1cc63e8dfdd73ffb4df18027fcf7958d5829e
52 changes: 0 additions & 52 deletions coderd/database/dbmem/dbmem.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3979,58 +3979,6 @@ func (q *FakeQuerier) GetProvisionerJobsByOrganizationAndStatusWithQueuePosition
defer q.mutex.RUnlock()

/*
-- name: GetProvisionerJobsByOrganizationAndStatusWithQueuePositionAndProvisioner :many
WITH unstarted_jobs AS (
SELECT
id, created_at
FROM
provisioner_jobs
WHERE
started_at IS NULL
),
queue_position AS (
SELECT
id,
ROW_NUMBER() OVER (ORDER BY created_at ASC) AS queue_position
FROM
unstarted_jobs
),
queue_size AS (
SELECT COUNT(*) AS count FROM unstarted_jobs
)
SELECT
sqlc.embed(pj),
COALESCE(qp.queue_position, 0) AS queue_position,
COALESCE(qs.count, 0) AS queue_size,
array_agg(DISTINCT pd.id) FILTER (WHERE pd.id IS NOT NULL)::uuid[] AS available_workers
FROM
provisioner_jobs pj
LEFT JOIN
queue_position qp ON qp.id = pj.id
LEFT JOIN
queue_size qs ON TRUE
LEFT JOIN
provisioner_daemons pd ON (
-- See AcquireProvisionerJob.
pj.started_at IS NULL
AND pj.organization_id = pd.organization_id
AND pj.provisioner = ANY(pd.provisioners)
AND provisioner_tagset_contains(pd.tags, pj.tags)
)
WHERE
(sqlc.narg('organization_id')::uuid IS NULL OR pj.organization_id = @organization_id)
AND (COALESCE(array_length(@status::provisioner_job_status[], 1), 1) > 0 OR pj.job_status = ANY(@status::provisioner_job_status[]))
GROUP BY
pj.id,
qp.queue_position,
qs.count
ORDER BY
pj.created_at DESC
LIMIT
sqlc.narg('limit')::int;

AMENDED QUERY:

-- name: GetProvisionerJobsByOrganizationAndStatusWithQueuePositionAndProvisioner :many
WITH pending_jobs AS (
SELECT
Expand Down