From cc8f19d49c7101354af1b10762094057ff29da0a Mon Sep 17 00:00:00 2001 From: mwojtyczka Date: Fri, 27 Oct 2023 18:53:28 +0200 Subject: [PATCH] reformatting --- src/databricks/labs/ucx/framework/parallel.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/databricks/labs/ucx/framework/parallel.py b/src/databricks/labs/ucx/framework/parallel.py index d8c0feabdd..50c360b1c4 100644 --- a/src/databricks/labs/ucx/framework/parallel.py +++ b/src/databricks/labs/ucx/framework/parallel.py @@ -27,8 +27,9 @@ def __init__(self, name, tasks: list[Callable[..., Result]], num_threads: int): self._default_log_every = 100 @classmethod - def gather(cls, name: str, tasks: list[Callable[..., Result]], num_threads: int = None) \ - -> (list[Result], list[Exception]): + def gather( + cls, name: str, tasks: list[Callable[..., Result]], num_threads: int | None = None + ) -> (list[Result], list[Exception]): if num_threads is None: num_threads = os.cpu_count() * 2 if num_threads < MIN_THREADS: