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

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

rechunker/api.py

@@ -209,7 +209,9 @@ class PythonCopySpecExecutor(PythonPipelineExecutor, CopySpecToPipelinesMixin):
     elif name.lower() == "lithops":
         from rechunker.executors.lithops import LithopsPipelineExecutor
 
-        class LithopsCopySpecExecutor(LithopsPipelineExecutor, CopySpecToPipelinesMixin):
+        class LithopsCopySpecExecutor(
+            LithopsPipelineExecutor, CopySpecToPipelinesMixin
+        ):
             pass
 
         return LithopsCopySpecExecutor()

rechunker/executors/lithops.py

@@ -6,6 +6,7 @@
 
 Task = Callable[[], None]
 
+
 class LithopsPipelineExecutor(PipelineExecutor[Task]):
     """An execution engine based on Lithops framework."""
 
@@ -24,19 +25,18 @@ def _prepare_input_data():
                         iterdata.append((None, stage.function, pipeline.config))
             return iterdata
 
-        def plan(config):     
+        def plan(config):
             iterdata = _prepare_input_data()
 
             if config is None:
                 fexec = lithops.FunctionExecutor(config=config)
             else:
                 fexec = lithops.FunctionExecutor()
-                
+
             fexec.map(map_function, iterdata[0])
             fexec.get_result()
 
         return plan
 
-    def execute_plan(self, plan: Task, config = None, **kwargs):
+    def execute_plan(self, plan: Task, config=None, **kwargs):
         plan(config)
-