Skip to content

Adding 'unsettled_*' tables#137

Merged
ealexa05 merged 1 commit intomainfrom
adding_tables_20251114
Nov 18, 2025
Merged

Adding 'unsettled_*' tables#137
ealexa05 merged 1 commit intomainfrom
adding_tables_20251114

Conversation

@ealexa05
Copy link
Contributor

@ealexa05 ealexa05 commented Nov 14, 2025

Asana: Add table to Fares_Data_Repository and DMAP Import Database

Tested locally, works:

16:05:48.936 [info] == Running 20251114204512 ExCubicIngestion.Repo.Migrations.AddMoreTablesForIngestion_20251114.up/0 forward

16:05:48.955 [debug] QUERY OK source="cubic_tables" db=3.7ms
INSERT INTO "cubic_tables" ("name","s3_prefix","is_active","is_raw","inserted_at","updated_at") VALUES ($1,$2,$3,$4,$5,$6) RETURNING "id" ["cubic_ods_qlik__edw_unsettled_cca_cash_count", "cubic/ods_qlik/EDW.UNSETTLED_CCA_CASH_COUNT/", true, true, ~U[2025-11-14 21:05:48Z], ~U[2025-11-14 21:05:48Z]]

16:05:48.957 [debug] QUERY OK source="cubic_ods_table_snapshots" db=0.7ms
INSERT INTO "cubic_ods_table_snapshots" ("table_id","snapshot_s3_key","inserted_at","updated_at") VALUES ($1,$2,$3,$4) RETURNING "id" [182, "cubic/ods_qlik/EDW.UNSETTLED_CCA_CASH_COUNT/LOAD00000001.csv.gz", ~U[2025-11-14 21:05:48Z], ~U[2025-11-14 21:05:48Z]]

16:05:48.958 [debug] QUERY OK source="cubic_tables" db=0.3ms
INSERT INTO "cubic_tables" ("name","s3_prefix","is_active","is_raw","inserted_at","updated_at") VALUES ($1,$2,$3,$4,$5,$6) RETURNING "id" ["cubic_ods_qlik__edw_unsettled_crdb_acq_conf", "cubic/ods_qlik/EDW.UNSETTLED_CRDB_ACQ_CONF/", true, true, ~U[2025-11-14 21:05:48Z], ~U[2025-11-14 21:05:48Z]]

16:05:48.958 [debug] QUERY OK source="cubic_ods_table_snapshots" db=0.3ms
INSERT INTO "cubic_ods_table_snapshots" ("table_id","snapshot_s3_key","inserted_at","updated_at") VALUES ($1,$2,$3,$4) RETURNING "id" [183, "cubic/ods_qlik/EDW.UNSETTLED_CRDB_ACQ_CONF/LOAD00000001.csv.gz", ~U[2025-11-14 21:05:48Z], ~U[2025-11-14 21:05:48Z]]

16:05:48.958 [debug] QUERY OK source="cubic_tables" db=0.2ms
INSERT INTO "cubic_tables" ("name","s3_prefix","is_active","is_raw","inserted_at","updated_at") VALUES ($1,$2,$3,$4,$5,$6) RETURNING "id" ["cubic_ods_qlik__edw_unsettled_crdb_chgbk", "cubic/ods_qlik/EDW.UNSETTLED_CRDB_CHGBK/", true, true, ~U[2025-11-14 21:05:48Z], ~U[2025-11-14 21:05:48Z]]

16:05:48.959 [debug] QUERY OK source="cubic_ods_table_snapshots" db=0.2ms
INSERT INTO "cubic_ods_table_snapshots" ("table_id","snapshot_s3_key","inserted_at","updated_at") VALUES ($1,$2,$3,$4) RETURNING "id" [184, "cubic/ods_qlik/EDW.UNSETTLED_CRDB_CHGBK/LOAD00000001.csv.gz", ~U[2025-11-14 21:05:48Z], ~U[2025-11-14 21:05:48Z]]

16:05:48.959 [debug] QUERY OK source="cubic_tables" db=0.2ms
INSERT INTO "cubic_tables" ("name","s3_prefix","is_active","is_raw","inserted_at","updated_at") VALUES ($1,$2,$3,$4,$5,$6) RETURNING "id" ["cubic_ods_qlik__edw_unsettled_device_cash_stc", "cubic/ods_qlik/EDW.UNSETTLED_DEVICE_CASH_STC/", true, true, ~U[2025-11-14 21:05:48Z], ~U[2025-11-14 21:05:48Z]]

16:05:48.959 [debug] QUERY OK source="cubic_ods_table_snapshots" db=0.2ms
INSERT INTO "cubic_ods_table_snapshots" ("table_id","snapshot_s3_key","inserted_at","updated_at") VALUES ($1,$2,$3,$4) RETURNING "id" [185, "cubic/ods_qlik/EDW.UNSETTLED_DEVICE_CASH_STC/LOAD00000001.csv.gz", ~U[2025-11-14 21:05:48Z], ~U[2025-11-14 21:05:48Z]]

16:05:48.959 [debug] QUERY OK source="cubic_tables" db=0.2ms
INSERT INTO "cubic_tables" ("name","s3_prefix","is_active","is_raw","inserted_at","updated_at") VALUES ($1,$2,$3,$4,$5,$6) RETURNING "id" ["cubic_ods_qlik__edw_unsettled_dist_order", "cubic/ods_qlik/EDW.UNSETTLED_DIST_ORDER/", true, true, ~U[2025-11-14 21:05:48Z], ~U[2025-11-14 21:05:48Z]]

16:05:48.960 [debug] QUERY OK source="cubic_ods_table_snapshots" db=0.2ms
INSERT INTO "cubic_ods_table_snapshots" ("table_id","snapshot_s3_key","inserted_at","updated_at") VALUES ($1,$2,$3,$4) RETURNING "id" [186, "cubic/ods_qlik/EDW.UNSETTLED_DIST_ORDER/LOAD00000001.csv.gz", ~U[2025-11-14 21:05:48Z], ~U[2025-11-14 21:05:48Z]]

16:05:48.960 [debug] QUERY OK source="cubic_tables" db=0.2ms
INSERT INTO "cubic_tables" ("name","s3_prefix","is_active","is_raw","inserted_at","updated_at") VALUES ($1,$2,$3,$4,$5,$6) RETURNING "id" ["cubic_ods_qlik__edw_unsettled_misc", "cubic/ods_qlik/EDW.UNSETTLED_MISC/", true, true, ~U[2025-11-14 21:05:48Z], ~U[2025-11-14 21:05:48Z]]

16:05:48.960 [debug] QUERY OK source="cubic_ods_table_snapshots" db=0.2ms
INSERT INTO "cubic_ods_table_snapshots" ("table_id","snapshot_s3_key","inserted_at","updated_at") VALUES ($1,$2,$3,$4) RETURNING "id" [187, "cubic/ods_qlik/EDW.UNSETTLED_MISC/LOAD00000001.csv.gz", ~U[2025-11-14 21:05:48Z], ~U[2025-11-14 21:05:48Z]]

16:05:48.960 [debug] QUERY OK source="cubic_tables" db=0.2ms
INSERT INTO "cubic_tables" ("name","s3_prefix","is_active","is_raw","inserted_at","updated_at") VALUES ($1,$2,$3,$4,$5,$6) RETURNING "id" ["cubic_ods_qlik__edw_unsettled_patron_order", "cubic/ods_qlik/EDW.UNSETTLED_PATRON_ORDER/", true, true, ~U[2025-11-14 21:05:48Z], ~U[2025-11-14 21:05:48Z]]

16:05:48.961 [debug] QUERY OK source="cubic_ods_table_snapshots" db=0.2ms
INSERT INTO "cubic_ods_table_snapshots" ("table_id","snapshot_s3_key","inserted_at","updated_at") VALUES ($1,$2,$3,$4) RETURNING "id" [188, "cubic/ods_qlik/EDW.UNSETTLED_PATRON_ORDER/LOAD00000001.csv.gz", ~U[2025-11-14 21:05:48Z], ~U[2025-11-14 21:05:48Z]]

16:05:48.961 [debug] QUERY OK source="cubic_tables" db=0.2ms
INSERT INTO "cubic_tables" ("name","s3_prefix","is_active","is_raw","inserted_at","updated_at") VALUES ($1,$2,$3,$4,$5,$6) RETURNING "id" ["cubic_ods_qlik__edw_unsettled_sale", "cubic/ods_qlik/EDW.UNSETTLED_SALE/", true, true, ~U[2025-11-14 21:05:48Z], ~U[2025-11-14 21:05:48Z]]

16:05:48.961 [debug] QUERY OK source="cubic_ods_table_snapshots" db=0.2ms
INSERT INTO "cubic_ods_table_snapshots" ("table_id","snapshot_s3_key","inserted_at","updated_at") VALUES ($1,$2,$3,$4) RETURNING "id" [189, "cubic/ods_qlik/EDW.UNSETTLED_SALE/LOAD00000001.csv.gz", ~U[2025-11-14 21:05:48Z], ~U[2025-11-14 21:05:48Z]]

16:05:48.961 [debug] QUERY OK source="cubic_tables" db=0.1ms
INSERT INTO "cubic_tables" ("name","s3_prefix","is_active","is_raw","inserted_at","updated_at") VALUES ($1,$2,$3,$4,$5,$6) RETURNING "id" ["cubic_ods_qlik__edw_unsettled_use", "cubic/ods_qlik/EDW.UNSETTLED_USE/", true, true, ~U[2025-11-14 21:05:48Z], ~U[2025-11-14 21:05:48Z]]

16:05:48.962 [debug] QUERY OK source="cubic_ods_table_snapshots" db=0.2ms
INSERT INTO "cubic_ods_table_snapshots" ("table_id","snapshot_s3_key","inserted_at","updated_at") VALUES ($1,$2,$3,$4) RETURNING "id" [190, "cubic/ods_qlik/EDW.UNSETTLED_USE/LOAD00000001.csv.gz", ~U[2025-11-14 21:05:48Z], ~U[2025-11-14 21:05:48Z]]

16:05:48.962 [info] == Migrated 20251114204512 in 0.0s

@ealexa05 ealexa05 requested a review from grejdi-mbta November 14, 2025 21:10
@ealexa05 ealexa05 merged commit 6867f8d into main Nov 18, 2025
3 checks passed
@ealexa05 ealexa05 deleted the adding_tables_20251114 branch November 18, 2025 16:58
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants