From af92cd62aacb4f3fb844c06dc5abfe4403e3e864 Mon Sep 17 00:00:00 2001 From: Edmund Higham Date: Wed, 31 Jul 2024 15:09:25 -0400 Subject: [PATCH] remove unapplicable feature flag --- batch/batch/driver/main.py | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/batch/batch/driver/main.py b/batch/batch/driver/main.py index c7b485be9f4..96fb8f19e4a 100644 --- a/batch/batch/driver/main.py +++ b/batch/batch/driver/main.py @@ -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', @@ -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))