diff options
Diffstat (limited to 'guix-data-service/jobs/load-new-guix-revision.scm')
| -rw-r--r-- | guix-data-service/jobs/load-new-guix-revision.scm | 21 |
1 files changed, 21 insertions, 0 deletions
diff --git a/guix-data-service/jobs/load-new-guix-revision.scm b/guix-data-service/jobs/load-new-guix-revision.scm index 038d74f..457f6cb 100644 --- a/guix-data-service/jobs/load-new-guix-revision.scm +++ b/guix-data-service/jobs/load-new-guix-revision.scm @@ -56,6 +56,7 @@ process-load-new-guix-revision-job select-job-for-commit select-jobs-and-events + select-recent-job-events select-unprocessed-jobs-and-events select-jobs-and-events-for-commit record-job-event @@ -1076,6 +1077,26 @@ RETURNING id;") (list commit)))) result)) +(define* (select-recent-job-events conn + #:key (limit 8)) + (define query + (string-append + " +SELECT + load_new_guix_revision_jobs.id, + load_new_guix_revision_jobs.commit, + load_new_guix_revision_jobs.source, + load_new_guix_revision_jobs.git_repository_id, + load_new_guix_revision_job_events.event, + load_new_guix_revision_job_events.occurred_at +FROM load_new_guix_revision_jobs +INNER JOIN load_new_guix_revision_job_events + ON load_new_guix_revision_job_events.job_id = load_new_guix_revision_jobs.id +ORDER BY load_new_guix_revision_job_events.occurred_at DESC +LIMIT " (number->string limit))) + + (exec-query conn query)) + (define (select-jobs-and-events conn before-id limit) (define query (string-append |