Skip to content

Commit

Permalink
reformatting
Browse files Browse the repository at this point in the history
  • Loading branch information
mwojtyczka committed Oct 27, 2023
1 parent 3a33475 commit cc8f19d
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions src/databricks/labs/ucx/framework/parallel.py
Original file line number Diff line number Diff line change
Expand Up @@ -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:
Expand Down

0 comments on commit cc8f19d

Please sign in to comment.