File tree Expand file tree Collapse file tree 2 files changed +1
-16
lines changed Expand file tree Collapse file tree 2 files changed +1
-16
lines changed Original file line number Diff line number Diff line change @@ -278,21 +278,6 @@ export function defineQueue(opts: QueueOptions): Queue {
278278 UPDATE plainjob_jobs SET status = ${ JobStatus . Pending } WHERE status = ${ JobStatus . Processing } AND next_run_at < @threshold
279279 ` ) ;
280280
281- const getAndMarkJobAsProcessingStmt = db . prepare ( `
282- UPDATE plainjob_jobs SET status = ${ JobStatus . Processing }
283- WHERE id = (
284- SELECT id FROM plainjob_jobs
285- WHERE status = ${ JobStatus . Pending } AND type = @type AND next_run_at <= @now
286- ORDER BY next_run_at LIMIT 1
287- )
288- ` ) ;
289-
290- const getUpdatedJobStmt = db . prepare ( `
291- SELECT * FROM plainjob_jobs
292- WHERE status = ${ JobStatus . Processing } AND type = @type AND next_run_at <= @now
293- ORDER BY next_run_at LIMIT 1
294- ` ) ;
295-
296281 const getJobIdToProcessNextStmt = db . prepare ( `
297282 SELECT id
298283 FROM plainjob_jobs
Original file line number Diff line number Diff line change @@ -424,7 +424,7 @@ export function getTestSuite(
424424 } ) ;
425425 } ) ;
426426
427- describe ( "worker" , async ( ) => {
427+ describe ( "process (queue and worker" , async ( ) => {
428428 let connection : Connection ;
429429
430430 beforeEach ( ( ) => {
You can’t perform that action at this time.
0 commit comments