Repository navigation
[DEV-16418] Update agency loader to account for Delta tables - #4797
Merged
Merged
Conversation
Sprint 226 Deploy
…pending-api into fix/dev-16418-update-for-agency-changes
…pending-api into fix/dev-16418-update-for-agency-changes
zachflanders-frb
previously approved these changes
Oct 7, 2026
zachflanders-frb
previously approved these changes
Oct 7, 2026
…pending-api into fix/dev-16418-update-for-agency-changes
zachflanders-frb
approved these changes
Oct 7, 2026
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Description:
Convert the agency loader to an EMR job that handles updating all relevant Postgres and Delta tables.
Technical Details:
Updates to the agency loader that take into account File D existing now as Postgres and Delta tables. This will handle updating all of the raw / bronze and int / silver tables across Postgres and Delta. The rpt / gold tables are updated by later steps in the pipeline.
Adding locking to the Delta table
.execute()method to address what appears to be a race condition by Spark when two jobs complete simultaneously. This will still allow Postgres jobs to process while the Spark jobs are force to run more synchronously.Requirements for PR Merge:
Explain N/A in above checklist: