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))