@@ -574,7 +574,7 @@ export class PgDriver extends BaseDriver<never, never, PGTransaction> {
574
574
} ) ;
575
575
try {
576
576
const results = await client . query < QueueRow > ( q , v ) ;
577
- if ( results . rowCount < 1 ) {
577
+ if ( ( results . rowCount as number ) < 1 ) {
578
578
throw new DriverNoMatchingAckError ( ack ) ;
579
579
}
580
580
} catch ( e ) {
@@ -624,7 +624,7 @@ export class PgDriver extends BaseDriver<never, never, PGTransaction> {
624
624
625
625
try {
626
626
const results = await client . query < QueueRow > ( q , v ) ;
627
- if ( results . rowCount < 1 ) {
627
+ if ( ( results . rowCount as number ) < 1 ) {
628
628
throw new DriverNoMatchingAckError ( ack ) ;
629
629
}
630
630
} catch ( e ) {
@@ -720,7 +720,7 @@ export class PgDriver extends BaseDriver<never, never, PGTransaction> {
720
720
721
721
try {
722
722
const results = await client . query < QueueRow > ( q , v ) ;
723
- if ( results . rowCount < 1 ) {
723
+ if ( ( results . rowCount as number ) < 1 ) {
724
724
throw new DriverNoMatchingAckError ( ack ) ;
725
725
}
726
726
} catch ( e ) {
@@ -759,7 +759,7 @@ export class PgDriver extends BaseDriver<never, never, PGTransaction> {
759
759
760
760
try {
761
761
const results = await client . query < QueueRow > ( q , v ) ;
762
- if ( results . rowCount < 1 ) {
762
+ if ( ( results . rowCount as number ) < 1 ) {
763
763
throw new DriverNoMatchingRefError ( "ERR_UNKNOWN_ACK_OR_EXPIRED" ) ;
764
764
}
765
765
} catch ( e ) {
@@ -800,7 +800,7 @@ export class PgDriver extends BaseDriver<never, never, PGTransaction> {
800
800
try {
801
801
const results = await client . query < QueueRow > ( q , v ) ;
802
802
803
- if ( results . rowCount < 1 ) {
803
+ if ( ( results . rowCount as number ) < 1 ) {
804
804
throw new DriverNoMatchingRefError ( ref ) ;
805
805
}
806
806
} catch ( e ) {
0 commit comments