diff --git a/pubtools/_pulp/tasks/garbage_collect.py b/pubtools/_pulp/tasks/garbage_collect.py index 0365fa83..732f6827 100644 --- a/pubtools/_pulp/tasks/garbage_collect.py +++ b/pubtools/_pulp/tasks/garbage_collect.py @@ -95,8 +95,7 @@ def clean_all_rpm_content(self): Criteria.with_unit_type(RpmUnit, unit_fields=["unit_id"]), Criteria.with_field( "cdn_published", - Matcher.less_than( - datetime.utcnow() - timedelta(days=arc_threshold)), + Matcher.less_than(datetime.utcnow() - timedelta(days=arc_threshold)), ), ) deleted_content = [] @@ -107,8 +106,7 @@ def clean_all_rpm_content(self): def handle_pages(page): batch_accumulator = [[unit.unit_id for unit in page.data]] if page.next: - batch_accumulator.extend( - f_flat_map(page.next, handle_pages).result()) + batch_accumulator.extend(f_flat_map(page.next, handle_pages).result()) return f_return(batch_accumulator) batches = f_flat_map(first_page, handle_pages).result()