Skip to content

Commit c4c765f

Browse files
committed
perfect logs
1 parent bf8a149 commit c4c765f

File tree

2 files changed

+3
-7
lines changed

2 files changed

+3
-7
lines changed

rollup/internal/controller/blob_uploader/blob_uploader.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ func (b *BlobUploader) UploadBlobToS3() {
7575

7676
// nothing to do if we don't have any pending batches
7777
if dbBatch == nil {
78-
log.Info("not found any un-uploaded batches")
78+
log.Debug("no pending batches to upload")
7979
return
8080
}
8181

rollup/internal/orm/batch.go

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -285,12 +285,8 @@ func (o *Batch) GetFirstUnuploadedBatchByPlatform(ctx context.Context, startBatc
285285
}
286286

287287
batch, err := o.GetBatchByIndex(ctx, BatchIndex)
288-
if err != nil {
289-
return nil, fmt.Errorf("Batch.GetLatestSuccessfulBlobUploadIndex error: %w", err)
290-
}
291-
292-
if len(batch.CommitTxHash) == 0 {
293-
log.Debug("got uncommitted un-uploaded batch", "index", batch.Index, "platform", int16(platform))
288+
if err != nil || len(batch.CommitTxHash) == 0 {
289+
log.Debug("got batch not ready for blob uploading", "batch_index", batch.Index, "platform", platform.String())
294290
return nil, nil
295291
}
296292

0 commit comments

Comments
 (0)