Skip to content

Commit 339c9fe

Browse files
committed
remove unapplicable feature flag
1 parent 8b40080 commit 339c9fe

File tree

1 file changed

+2
-5
lines changed

1 file changed

+2
-5
lines changed

batch/batch/driver/main.py

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1690,10 +1690,7 @@ async def compact(tx: Transaction, target: dict):
16901690
await compact(target)
16911691

16921692

1693-
async def compact_agg_billing_project_users_by_date_table(app, db: Database):
1694-
if not app['feature_flags']['compact_billing_tables']:
1695-
return
1696-
1693+
async def compact_agg_billing_project_users_by_date_table(db: Database):
16971694
@transaction(db)
16981695
async def compact(tx: Transaction, target: dict):
16991696
original_usage = await tx.execute_and_fetchone(
@@ -1881,7 +1878,7 @@ async def close_and_wait():
18811878
task_manager.ensure_future(periodically_call(60, compact_agg_billing_project_users_by_date_table, app, db))
18821879
task_manager.ensure_future(periodically_call(60, delete_committed_job_groups_inst_coll_staging_records, db))
18831880
task_manager.ensure_future(periodically_call(60, delete_prev_cancelled_job_group_cancellable_resources_records, db))
1884-
task_manager.ensure_future(periodically_call(60, compact_job_group_cancellable_resources_records, app, db))
1881+
task_manager.ensure_future(periodically_call(60, compact_job_group_cancellable_resources_records, db))
18851882
task_manager.ensure_future(periodically_call(60, delete_dead_job_group_cancellable_resources_records, db))
18861883

18871884

0 commit comments

Comments
 (0)