There was an error while loading. Please reload this page.
1 parent 0c32f54 commit 036d3e8Copy full SHA for 036d3e8
1 file changed
apps/bfd-pipeline-idr/pipeline_utils.py
@@ -195,7 +195,7 @@ def prune_stale_non_part_d_claims(
195
196
prune_query = stale_non_part_d_claims_query(claim_table)
197
198
- total_row_counts = {
+ total_row_counts: dict[str, int] = {
199
item_table: 0,
200
claim_table: 0,
201
}
@@ -206,7 +206,8 @@ def prune_stale_non_part_d_claims(
206
with conn.transaction():
207
for target_table in [item_table, claim_table]:
208
res = conn.execute(
209
- f"""DELETE FROM {target_table} WHERE clm_uniq_id IN ({prune_query})""" # type: ignore
+ f"""DELETE FROM {target_table} WHERE clm_uniq_id IN ({prune_query})""", # type: ignore
210
+ (),
211
)
212
213
total_row_counts[target_table] += res.rowcount
0 commit comments