diff --git a/input/chainsync/chainsync.go b/input/chainsync/chainsync.go index 4ae3b8e..7d1c0f6 100644 --- a/input/chainsync/chainsync.go +++ b/input/chainsync/chainsync.go @@ -409,7 +409,12 @@ func (c *ChainSync) handleRollForward( for t, transaction := range block.Transactions() { resolvedInputs, err := resolveTransactionInputs(transaction, c) if err != nil { - return err + slog.Error( + "failed to resolve transaction inputs via Kupo, emitting without resolved inputs", + "err", + err, + ) + resolvedInputs = nil } if t < 0 || t > math.MaxUint32 { return errors.New("invalid number of transactions") @@ -491,7 +496,12 @@ func (c *ChainSync) handleBlockFetchBlock( for t, transaction := range block.Transactions() { resolvedInputs, err := resolveTransactionInputs(transaction, c) if err != nil { - return err + slog.Error( + "failed to resolve transaction inputs via Kupo, emitting without resolved inputs", + "err", + err, + ) + resolvedInputs = nil } if t < 0 || t > math.MaxUint32 { return errors.New("invalid number of transactions")