Skip to content

Commit

Permalink
fix: fix
Browse files Browse the repository at this point in the history
  • Loading branch information
alexgao001 committed Aug 7, 2024
1 parent a75bdfe commit dcb4386
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions syncer/verifier.go
Original file line number Diff line number Diff line change
Expand Up @@ -51,10 +51,9 @@ func (s *BlobSyncer) verify() error {
}
bundleName := verifyBlock.BundleName

//
if bundleName == "blobs_s41123787_e41123986_calibrated_1722946138" {
if bundleName == "blobs_s9681816_e9681845_calibrated_1723010409_calibrated_1723016644" {
// update the status
if err := s.blobDao.UpdateBlocksStatus(41123787, 41123986, db.Verified); err != nil {
if err := s.blobDao.UpdateBlocksStatus(9681816, 9681845, db.Verified); err != nil {
return err
}
if err = s.blobDao.UpdateBundleStatus(bundleName, db.Sealed); err != nil {
Expand Down Expand Up @@ -280,7 +279,7 @@ func (s *BlobSyncer) verifyBlobsAtBlock(blockID uint64, sidecars []*types.Genera
// get blob from bundle service
blobFromBundle, err := s.bundleClient.GetObject(s.getBucketName(), bundleName, types.GetBlobName(blockID, i))
if err != nil {
if err == cmn.ErrorBundleObjectNotExist {
if errors.Is(err, cmn.ErrorBundleObjectNotExist) {
logging.Logger.Errorf("the bundle object not found in bundle service, object=%s", types.GetBlobName(blockID, i))
return ErrVerificationFailed
}
Expand Down Expand Up @@ -334,8 +333,9 @@ func (s *BlobSyncer) reUploadBundle(bundleName string) error {
if err := s.blobDao.UpdateBundleStatus(bundleName, db.Deprecated); err != nil {
return err
}
parts := strings.Split(bundleName, "_")
newBundleName := parts[0] + "_" + parts[1] + "_" + parts[2] + "_calibrated_" + util.Int64ToString(time.Now().Unix())

newBundleName := bundleName + "_calibrated_" + util.Int64ToString(time.Now().Unix())
startBlockID, endBlockID, err := types.ParseBundleName(bundleName)
if err != nil {
return err
Expand Down

0 comments on commit dcb4386

Please sign in to comment.