remove unapplicable feature flag

hail-is · Jul 31, 2024 · 339c9fe · 339c9fe
1 parent 8b40080
commit 339c9fe
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/batch/batch/driver/main.py b/batch/batch/driver/main.py
@@ -1690,10 +1690,7 @@ async def compact(tx: Transaction, target: dict):
         await compact(target)
 
 
-async def compact_agg_billing_project_users_by_date_table(app, db: Database):
-    if not app['feature_flags']['compact_billing_tables']:
-        return
-
+async def compact_agg_billing_project_users_by_date_table(db: Database):
     @transaction(db)
     async def compact(tx: Transaction, target: dict):
         original_usage = await tx.execute_and_fetchone(
@@ -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))