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

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

dask4dvc/__init__.py

@@ -1,4 +1,5 @@
 """The 'dask4dvc' package."""
+
 import importlib.metadata
 import logging
 import sys

dask4dvc/cli/__init__.py

@@ -1,4 +1,5 @@
 """The 'dask4dvc' CLI."""
+
 from dask4dvc.cli import main
 
 __all__ = ["main"]

dask4dvc/dvc_repro.py

@@ -1,4 +1,5 @@
 """Dask4DVC to DVC repo interface."""
+
 import dataclasses
 import logging
 import subprocess
@@ -161,7 +162,10 @@ def parallel_submit(
     client: dask.distributed.Client,
     repo: dvc.repo.Repo,
     stages: typing.Dict[PipelineStage, str],
-) -> typing.Tuple[typing.Dict[PipelineStage, dask.distributed.Future], typing.List[str],]:
+) -> typing.Tuple[
+    typing.Dict[PipelineStage, dask.distributed.Future],
+    typing.List[str],
+]:
     """Submit experiments in parallel."""
     mapping = {}
     queue_entries = get_all_queue_entries(repo)

dask4dvc/utils/dask.py

@@ -1,4 +1,5 @@
 """Utils that are related to 'dask'."""
+
 import logging
 import pathlib
 import typing

tests/conftest.py

@@ -1,4 +1,5 @@
 """global pytest fixtures."""
+
 import os
 import pathlib
 import shutil

tests/test_dask4dvc.py

@@ -1,4 +1,5 @@
 """Test the 'dask4dvc' package."""
+
 import dask4dvc
 
 

tests/test_repro.py

@@ -1,4 +1,5 @@
 """Test the 'dask4dvc' CLI."""
+
 import pathlib
 import random
 

tests/test_run.py

@@ -1,4 +1,5 @@
 """Test the 'dask4dvc' CLI."""
+
 import pathlib
 import random
 import typing