diff --git a/.github/workflows/mypy.yml b/.github/workflows/mypy.yml index 98f91e4f..cce977e1 100644 --- a/.github/workflows/mypy.yml +++ b/.github/workflows/mypy.yml @@ -18,7 +18,7 @@ jobs: fail-fast: false matrix: os: ["ubuntu-latest"] - python-version: ["3.9"] + python-version: ["3.11"] steps: - name: Checkout source diff --git a/cubed/runtime/executors/asyncio.py b/cubed/runtime/executors/asyncio.py index 84c58115..7e4ab86d 100644 --- a/cubed/runtime/executors/asyncio.py +++ b/cubed/runtime/executors/asyncio.py @@ -53,7 +53,7 @@ async def async_map_unordered( if backup: if not backup.done() or not backup.exception(): continue - raise task.exception() + raise task.exception() # type: ignore end_times[task] = time.monotonic() if return_stats: result, stats = task.result() diff --git a/cubed/runtime/executors/python_async.py b/cubed/runtime/executors/python_async.py index a19df14c..a2a61f97 100644 --- a/cubed/runtime/executors/python_async.py +++ b/cubed/runtime/executors/python_async.py @@ -128,6 +128,7 @@ async def async_execute_dag( compute_arrays_in_parallel: Optional[bool] = None, **kwargs, ) -> None: + concurrent_executor: Executor use_processes = kwargs.pop("use_processes", False) if use_processes: max_workers = kwargs.pop("max_workers", None) diff --git a/setup.cfg b/setup.cfg index 8eba3c7a..62965f08 100644 --- a/setup.cfg +++ b/setup.cfg @@ -24,6 +24,8 @@ ignore_missing_imports = True ignore_missing_imports = True [mypy-array_api_compat.*] ignore_missing_imports = True +[mypy-cloudpickle.*] +ignore_missing_imports = True [mypy-coiled.*] ignore_missing_imports = True [mypy-dask.*]