Skip to content

Commit

Permalink
remove unapplicable feature flag
Browse files Browse the repository at this point in the history
  • Loading branch information
ehigham committed Jul 31, 2024
1 parent 8b40080 commit af92cd6
Showing 1 changed file with 1 addition and 4 deletions.
5 changes: 1 addition & 4 deletions batch/batch/driver/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -1493,9 +1493,6 @@ async def delete_prev_cancelled_job_group_cancellable_resources_records(db: Data


async def compact_job_group_cancellable_resources_records(app, db: Database):
if not app['feature_flags']['compact_billing_tables']:
return

keyfields = [
'batch_id',
'update_id',
Expand Down Expand Up @@ -1881,7 +1878,7 @@ async def close_and_wait():
task_manager.ensure_future(periodically_call(60, compact_agg_billing_project_users_by_date_table, app, db))
task_manager.ensure_future(periodically_call(60, delete_committed_job_groups_inst_coll_staging_records, db))
task_manager.ensure_future(periodically_call(60, delete_prev_cancelled_job_group_cancellable_resources_records, db))
task_manager.ensure_future(periodically_call(60, compact_job_group_cancellable_resources_records, app, db))
task_manager.ensure_future(periodically_call(60, compact_job_group_cancellable_resources_records, db))
task_manager.ensure_future(periodically_call(60, delete_dead_job_group_cancellable_resources_records, db))


Expand Down

0 comments on commit af92cd6

Please sign in to comment.