me/neoq
1
0
Fork 0
mirror of https://github.com/acaloiaro/neoq synced 2026-07-21 18:29:08 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Do not compare error's string output

Browse source
This commit is contained in:
Juan C. Müller 2023-02-19 10:32:09 -05:00
parent da96409f30
commit e3fa7d96f8
No known key found for this signature in database
GPG key ID: A76E55A7FBA1E283
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
postgres_backend.go
View file

@ -538,7 +538,7 @@ func (w PgBackend) start(ctx context.Context, queue string) (err error) {
}
if err != nil {
if err.Error() == "no rows in result set" {
if errors.Is(err, pgx.ErrNoRows) {
err = nil
} else {
w.logger.Error("error handling job", err, "job_id", jobID)
@ -660,7 +660,7 @@ func (w PgBackend) pendingJobs(ctx context.Context, queue string) (jobsCh chan i
for {
jobID, err := w.getPendingJobID(ctx, conn, queue)
if err != nil {
if err.Error() != "no rows in result set" {
if !errors.Is(err, pgx.ErrNoRows) {
w.logger.Error("failed to fetch pending job", err, "job_id", jobID)
} else {
// done fetching pending jobs