diff --git a/queue.go b/queue.go index ad2118a..52480b3 100644 --- a/queue.go +++ b/queue.go @@ -3,6 +3,7 @@ package main import ( "context" "fmt" + "strings" "time" "github.com/google/uuid" @@ -101,7 +102,7 @@ func (q Queue) syn(ctx context.Context) ([]byte, []byte, error) { `, reservation) if err := row.Err(); err != nil { return nil, nil, fmt.Errorf("failed to query reservation: %w", err) - } else if err := row.Scan(&payload); err != nil { + } else if err := row.Scan(&payload); err != nil && !strings.Contains(err.Error(), "no rows in result") { return nil, nil, fmt.Errorf("failed to parse reservation: %w", err) }