Skip to content

Commit e2636ec

Browse files
authored
Stu/prune external txs (#213)
1 parent 8cc02fb commit e2636ec

File tree

3 files changed

+649
-8
lines changed

3 files changed

+649
-8
lines changed

stores/utxo/aerospike/create.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -854,8 +854,10 @@ func (s *Store) storeExternallyWithLock(
854854
}
855855

856856
// Write to external blob storage (now protected by lock - no duplicate work)
857+
// NOTE: Pass WithDeleteAt(0) to prevent DAH file creation. The pruner service will manage
858+
// deletion of external files directly when pruning Aerospike records.
857859
timeStart := time.Now()
858-
if err := s.externalStore.Set(ctx, bItem.txHash[:], fileType, blobData); err != nil && !errors.Is(err, errors.ErrBlobAlreadyExists) {
860+
if err := s.externalStore.Set(ctx, bItem.txHash[:], fileType, blobData, options.WithDeleteAt(0)); err != nil && !errors.Is(err, errors.ErrBlobAlreadyExists) {
859861
utils.SafeSend[error](bItem.done, errors.NewStorageError("[%s] error writing to external store [%s]", funcName, bItem.txHash.String()))
860862
return
861863
}

0 commit comments

Comments
 (0)