From 2977b4271e07745b71a29b0a7239ea125549e217 Mon Sep 17 00:00:00 2001 From: hunterpack Date: Fri, 6 Mar 2026 14:29:41 -0600 Subject: [PATCH 1/2] push on master and release branch staging tags --- .github/workflows/build.yml | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/.github/workflows/build.yml b/.github/workflows/build.yml index c015bed1..14c35ce1 100644 --- a/.github/workflows/build.yml +++ b/.github/workflows/build.yml @@ -1,6 +1,9 @@ name: Build Docker Image on: + push: + branches: + - master workflow_dispatch: concurrency: @@ -28,7 +31,7 @@ jobs: run: | if [ "${{ github.ref }}" = "refs/heads/master" ]; then IMAGE_TAG="stellar/stellar-etl:${SHORT_SHA}" - elif [ "${{ github.ref }}" = "refs/heads/staging" ]; then + elif [[ "${{ github.ref }}" == refs/heads/release* ]]; then IMAGE_TAG="stellar/stellar-etl-staging:${SHORT_SHA}" else IMAGE_TAG="stellar/stellar-etl-dev:${SHORT_SHA}" @@ -68,7 +71,7 @@ jobs: run: | if [ "${{ github.ref }}" = "refs/heads/master" ]; then GAR_IMAGE="us-central1-docker.pkg.dev/hubble-261722/stellar-etl/stellar-etl:${SHORT_SHA}" - elif [ "${{ github.ref }}" = "refs/heads/staging" ]; then + elif [[ "${{ github.ref }}" == refs/heads/release* ]]; then GAR_IMAGE="us-central1-docker.pkg.dev/hubble-261722/stellar-etl/stellar-etl-staging:${SHORT_SHA}" else GAR_IMAGE="us-central1-docker.pkg.dev/hubble-261722/stellar-etl/stellar-etl-dev:${SHORT_SHA}" From 54aba986289fb2b4073ccd418b7195485abcd339 Mon Sep 17 00:00:00 2001 From: hunterpack Date: Tue, 7 Apr 2026 16:07:54 -0500 Subject: [PATCH 2/2] fix uint32 bug --- internal/transform/schema.go | 2 +- internal/transform/schema_parquet.go | 2 +- internal/transform/transaction.go | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/transform/schema.go b/internal/transform/schema.go index 8b76b861..ea7f5a0c 100644 --- a/internal/transform/schema.go +++ b/internal/transform/schema.go @@ -60,7 +60,7 @@ type TransactionOutput struct { FeeAccount string `json:"fee_account,omitempty"` FeeAccountMuxed string `json:"fee_account_muxed,omitempty"` InnerTransactionHash string `json:"inner_transaction_hash,omitempty"` - NewMaxFee uint32 `json:"new_max_fee,omitempty"` + NewMaxFee int64 `json:"new_max_fee,omitempty"` LedgerBounds string `json:"ledger_bounds"` MinAccountSequence null.Int `json:"min_account_sequence"` MinAccountSequenceAge null.Int `json:"min_account_sequence_age"` diff --git a/internal/transform/schema_parquet.go b/internal/transform/schema_parquet.go index 829ab047..c7c3698b 100644 --- a/internal/transform/schema_parquet.go +++ b/internal/transform/schema_parquet.go @@ -51,7 +51,7 @@ type TransactionOutputParquet struct { FeeAccount string `parquet:"name=fee_account, type=BYTE_ARRAY, convertedtype=UTF8, encoding=PLAIN_DICTIONARY"` FeeAccountMuxed string `parquet:"name=fee_account_muxed, type=BYTE_ARRAY, convertedtype=UTF8, encoding=PLAIN_DICTIONARY"` InnerTransactionHash string `parquet:"name=inner_transaction_hash, type=BYTE_ARRAY, convertedtype=UTF8, encoding=PLAIN_DICTIONARY"` - NewMaxFee int64 `parquet:"name=new_max_fee, type=INT64, convertedtype=UINT_64"` + NewMaxFee int64 `parquet:"name=new_max_fee, type=INT64"` LedgerBounds string `parquet:"name=ledger_bounds, type=BYTE_ARRAY, convertedtype=UTF8, encoding=PLAIN_DICTIONARY"` MinAccountSequence int64 `parquet:"name=min_account_sequence, type=INT64"` MinAccountSequenceAge int64 `parquet:"name=min_account_sequence_age, type=INT64"` diff --git a/internal/transform/transaction.go b/internal/transform/transaction.go index cd35e378..1322ebef 100644 --- a/internal/transform/transaction.go +++ b/internal/transform/transaction.go @@ -291,7 +291,7 @@ func TransformTransaction(transaction ingest.LedgerTransaction, lhe xdr.LedgerHe transformedTransaction.FeeAccount = feeAccount.Address() innerHash := transaction.Result.InnerHash() transformedTransaction.InnerTransactionHash = hex.EncodeToString(innerHash[:]) - transformedTransaction.NewMaxFee = uint32(transaction.Envelope.FeeBumpFee()) + transformedTransaction.NewMaxFee = int64(transaction.Envelope.FeeBumpFee()) txSigners, err := getTxSigners(transaction.Envelope.FeeBump.Signatures) if err != nil { return TransactionOutput{}, err