pre-commit and remove RmqCoordinator to tests/util only

src/plumpy/__init__.py

@@ -18,9 +18,9 @@
 from .process_listener import *
 from .process_states import *
 from .processes import *
+from .rmq import *
 from .utils import *
 from .workchains import *
-from .rmq import *
 
 __all__ = (
     events.__all__

src/plumpy/futures.py

@@ -88,6 +88,4 @@ def create_task(coro: Callable[[], Awaitable[Any]], loop: Optional[asyncio.Abstr
     # asyncio.run_coroutine_threadsafe(run_task(), loop)
     # return future
 
-    return asyncio.wrap_future(
-        asyncio.run_coroutine_threadsafe(coro(), loop)
-    )
+    return asyncio.wrap_future(asyncio.run_coroutine_threadsafe(coro(), loop))

src/plumpy/message.py

@@ -10,8 +10,6 @@
 from plumpy.coordinator import Coordinator
 from plumpy.exceptions import PersistenceError, TaskRejectedError
 
-from plumpy.exceptions import PersistenceError, TaskRejectedError
-
 from . import loaders, persistence
 from .utils import PID_TYPE
 

src/plumpy/processes.py

@@ -1,6 +1,8 @@
 # -*- coding: utf-8 -*-
 """The main Process module"""
 
+from __future__ import annotations
+
 import abc
 import asyncio
 import concurrent.futures

src/plumpy/rmq/communications.py

@@ -78,11 +78,11 @@ def converted(communicator: kiwipy.Communicator, *args: Any, **kwargs: Any) -> k
 
     return converted
 
+
 T = TypeVar('T', bound=kiwipy.Communicator)
 
-def wrap_communicator(
-    communicator: T, loop: Optional[asyncio.AbstractEventLoop] = None
-) -> 'LoopCommunicator[T]':
+
+def wrap_communicator(communicator: T, loop: Optional[asyncio.AbstractEventLoop] = None) -> 'LoopCommunicator[T]':
     """
     Wrap a communicator such that all callbacks made to any subscribers are scheduled on the
     given event loop.

src/plumpy/rmq/futures.py

@@ -10,7 +10,7 @@
 
 import kiwipy
 
-__all__ = ['wrap_to_concurrent_future', 'unwrap_kiwi_future']
+__all__ = ['unwrap_kiwi_future', 'wrap_to_concurrent_future']
 
 
 def _convert_future_exc(exc):
@@ -112,6 +112,7 @@ def wrap_to_concurrent_future(future: asyncio.Future[Any]) -> kiwipy.Future:
     _chain_future(future, new_future)
     return new_future
 
+
 # XXX: this required in aiida-core, see if really need this unwrap.
 def unwrap_kiwi_future(future: kiwipy.Future) -> kiwipy.Future:
     """