Skip to content

Commit df7cf1c

Browse files
committed
update etl processor
1 parent bc170c2 commit df7cf1c

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

ingest/processors/ledger_processor/ledger.go

+8-1
Original file line numberDiff line numberDiff line change
@@ -200,7 +200,14 @@ func getTransactionPhase(transactionPhase []xdr.TransactionPhase) (transactionEn
200200
switch component.Type {
201201
case 0:
202202
transactionSlice = append(transactionSlice, component.TxsMaybeDiscountedFee.Txs...)
203-
203+
case 1:
204+
for _, stage := range phase.ParallelTxsComponent.ExecutionStages {
205+
for _, cluster := range stage {
206+
for _, envelope := range cluster {
207+
transactionSlice = append(transactionSlice, envelope)
208+
}
209+
}
210+
}
204211
default:
205212
panic(fmt.Sprintf("Unsupported TxSetComponentType: %d", component.Type))
206213
}

0 commit comments

Comments
 (0)