processing jobs bugfixes
This commit is contained in:
		
							parent
							
								
									5385bfeb6e
								
							
						
					
					
						commit
						7e8e1e1f07
					
				
					 2 changed files with 6 additions and 4 deletions
				
			
		| 
						 | 
				
			
			@ -50,6 +50,7 @@ func FailProcessingJob(jobid int64, jobErr error) error {
 | 
			
		|||
	var params sqlc.FailProcessingJobParams
 | 
			
		||||
	params.ID = jobid
 | 
			
		||||
	params.Error.String = jobErr.Error()
 | 
			
		||||
	params.Error.Valid = true
 | 
			
		||||
	err := query.FailProcessingJob(context.Background(), params)
 | 
			
		||||
	if err != nil {
 | 
			
		||||
		slog.Error("Unable to mark processing job as failed", "job-id", jobid, "error", err)
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -16,10 +16,6 @@ SET completed = NOW(),
 | 
			
		|||
  status = 'completed'
 | 
			
		||||
WHERE id = $1;
 | 
			
		||||
 | 
			
		||||
-- name: GetJobsForFile :many
 | 
			
		||||
SELECT * FROM processing_jobs
 | 
			
		||||
WHERE file_id = $1;
 | 
			
		||||
 | 
			
		||||
-- name: GetJob :one
 | 
			
		||||
SELECT * FROM processing_jobs
 | 
			
		||||
WHERE id = $1
 | 
			
		||||
| 
						 | 
				
			
			@ -34,3 +30,8 @@ WHERE id = $2;
 | 
			
		|||
 | 
			
		||||
-- name: GetAllJobs :many
 | 
			
		||||
SELECT * FROM processing_jobs;
 | 
			
		||||
 | 
			
		||||
-- name: GetJobsForFile :many
 | 
			
		||||
SELECT * FROM processing_jobs
 | 
			
		||||
WHERE file_id = $1
 | 
			
		||||
ORDER BY created DESC;
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
		Loading…
	
	Add table
		
		Reference in a new issue