fix: cast to int32

This commit is contained in:
mrkaye97
2025-09-15 16:06:40 -04:00
parent 97eb56b5b4
commit 36edd93fb7
+1 -1
View File
@@ -275,7 +275,7 @@ func (p *payloadStoreRepositoryImpl) ProcessPayloadWAL(ctx context.Context, part
walRecords, err := p.queries.PollPayloadWALForRecordsToOffload(ctx, tx, sqlcv1.PollPayloadWALForRecordsToOffloadParams{
Polllimit: int32(pollLimit),
Partitionnumber: partitionNumber,
Partitionnumber: int32(partitionNumber),
})
hasMoreWALRecords := len(walRecords) == pollLimit