[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

pubtools/_pulp/tasks/garbage_collect.py

@@ -11,8 +11,8 @@
 LOG = logging.getLogger("pubtools.pulp")
 step = PulpTask.step
 
-UNASSOCIATE_BATCH_LIMIT = int(
-    os.getenv("PULP_GC_UNASSOCIATE_BATCH_LIMIT", "10000"))
+UNASSOCIATE_BATCH_LIMIT = int(os.getenv("PULP_GC_UNASSOCIATE_BATCH_LIMIT", "10000"))
+
 
 class GarbageCollect(PulpClientService, PulpTask):
     """Perform garbage collection on Pulp data.
@@ -104,11 +104,14 @@ def clean_all_rpm_content(self):
 
         while True:
             delete_arc_tasks = list(
-                arc_repo.remove_content(criteria=criteria,
-                                        limit=UNASSOCIATE_BATCH_LIMIT)
+                arc_repo.remove_content(
+                    criteria=criteria, limit=UNASSOCIATE_BATCH_LIMIT
+                )
             )
             # The pulp client returns task(s) wrapped in a list
-            arc_tasks = list(filter(lambda x: x.repo_id == "all-rpm-content", delete_arc_tasks))
+            arc_tasks = list(
+                filter(lambda x: x.repo_id == "all-rpm-content", delete_arc_tasks)
+            )
             for task in arc_tasks:
                 for unit in task.units:
                     LOG.info("Old all-rpm-content deleted: %s", unit.name)
@@ -117,14 +120,14 @@ def clean_all_rpm_content(self):
             # Assuming the client can return multiple (python) tasks.
             # If all tasks delete less units than the batch limit,
             # implying all relevant units have been unassociated.
-            if not arc_tasks or \
-                    not any([t for t in arc_tasks
-                             if len(t.units) < UNASSOCIATE_BATCH_LIMIT]):
+            if not arc_tasks or not any(
+                [t for t in arc_tasks if len(t.units) < UNASSOCIATE_BATCH_LIMIT]
+            ):
                 break
 
         if not deleted_content:
-            LOG.info("No all-rpm-content found older than %s",
-                     arc_threshold)
+            LOG.info("No all-rpm-content found older than %s", arc_threshold)
+
 
 def entry_point():
     with GarbageCollect() as instance: