diff --git a/internal/manager/persistence/sqlc/query_jobs.sql b/internal/manager/persistence/sqlc/query_jobs.sql index 964f232c..154fbeec 100644 --- a/internal/manager/persistence/sqlc/query_jobs.sql +++ b/internal/manager/persistence/sqlc/query_jobs.sql @@ -1,7 +1,4 @@ --- Jobs / Tasks queries --- - -- name: CreateJob :exec INSERT INTO jobs ( created_at, diff --git a/internal/manager/persistence/sqlc/query_jobs.sql.go b/internal/manager/persistence/sqlc/query_jobs.sql.go index 2a7fd441..4fd399fb 100644 --- a/internal/manager/persistence/sqlc/query_jobs.sql.go +++ b/internal/manager/persistence/sqlc/query_jobs.sql.go @@ -64,7 +64,6 @@ func (q *Queries) CountWorkersFailingTask(ctx context.Context, taskID int64) (in } const createJob = `-- name: CreateJob :exec - INSERT INTO jobs ( created_at, uuid, @@ -93,7 +92,6 @@ type CreateJobParams struct { StorageShamanCheckoutID string } -// Jobs / Tasks queries func (q *Queries) CreateJob(ctx context.Context, arg CreateJobParams) error { _, err := q.db.ExecContext(ctx, createJob, arg.CreatedAt, diff --git a/internal/manager/persistence/sqlc/query_workers.sql b/internal/manager/persistence/sqlc/query_workers.sql index a96d84cf..7fe3d93c 100644 --- a/internal/manager/persistence/sqlc/query_workers.sql +++ b/internal/manager/persistence/sqlc/query_workers.sql @@ -1,7 +1,4 @@ --- Worker queries --- - -- name: CreateWorker :one INSERT INTO workers ( created_at, diff --git a/internal/manager/persistence/sqlc/query_workers.sql.go b/internal/manager/persistence/sqlc/query_workers.sql.go index fe25fe80..d5467025 100644 --- a/internal/manager/persistence/sqlc/query_workers.sql.go +++ b/internal/manager/persistence/sqlc/query_workers.sql.go @@ -27,7 +27,6 @@ func (q *Queries) AddWorkerTagMembership(ctx context.Context, arg AddWorkerTagMe } const createWorker = `-- name: CreateWorker :one - INSERT INTO workers ( created_at, uuid, @@ -79,7 +78,6 @@ type CreateWorkerParams struct { CanRestart bool } -// Worker queries func (q *Queries) CreateWorker(ctx context.Context, arg CreateWorkerParams) (int64, error) { row := q.db.QueryRowContext(ctx, createWorker, arg.CreatedAt,