fix: Apply the new isort rule by ruff

lablup · Sep 8, 2023 · 359ec03 · 359ec03
1 parent 0b54c62
commit 359ec03
Show file tree

Hide file tree

Showing 10 changed files with 23 additions and 22 deletions.
diff --git a/examples/ordering-by-exit-server.py b/examples/ordering-by-exit-server.py
@@ -2,11 +2,11 @@
 import json
 import signal
 
-from callosum.rpc import Peer
+from callosum.lower.zeromq import ZeroMQAddress, ZeroMQRPCTransport
 from callosum.ordering import (
     ExitOrderedAsyncScheduler,
 )
-from callosum.lower.zeromq import ZeroMQAddress, ZeroMQRPCTransport
+from callosum.rpc import Peer
 
 
 async def handle_echo(request):

diff --git a/examples/ordering-by-key-server.py b/examples/ordering-by-key-server.py
@@ -2,11 +2,11 @@
 import json
 import signal
 
-from callosum.rpc import Peer
+from callosum.lower.zeromq import ZeroMQAddress, ZeroMQRPCTransport
 from callosum.ordering import (
     KeySerializedAsyncScheduler,
 )
-from callosum.lower.zeromq import ZeroMQAddress, ZeroMQRPCTransport
+from callosum.rpc import Peer
 
 
 async def handle_echo(request):

diff --git a/examples/ordering-client.py b/examples/ordering-client.py
@@ -1,8 +1,8 @@
 import asyncio
 import json
 
-from callosum.rpc import Peer
 from callosum.lower.zeromq import ZeroMQAddress, ZeroMQRPCTransport
+from callosum.rpc import Peer
 
 
 async def call() -> None:

diff --git a/examples/simple-client-redis.py b/examples/simple-client-redis.py
@@ -4,11 +4,11 @@
 import random
 import secrets
 
-from callosum.rpc import Peer
 from callosum.lower.rpc_redis import (
     RedisStreamAddress,
     RPCRedisTransport,
 )
+from callosum.rpc import Peer
 
 
 async def call():

diff --git a/examples/simple-client-thrift.py b/examples/simple-client-thrift.py
@@ -6,6 +6,7 @@
 import textwrap
 
 import thriftpy2 as thriftpy
+
 from callosum.lower.zeromq import ZeroMQAddress, ZeroMQRPCTransport
 from callosum.rpc import Peer, RPCUserError
 from callosum.serialize import noop_deserializer, noop_serializer

diff --git a/examples/simple-consumer-redis.py b/examples/simple-consumer-redis.py
@@ -10,12 +10,12 @@
 import os
 import signal
 
-from callosum.pubsub import (
-    Consumer,
-)
 from callosum.lower.dispatch_redis import (
-    RedisStreamAddress,
     DispatchRedisTransport,
+    RedisStreamAddress,
+)
+from callosum.pubsub import (
+    Consumer,
 )
 
 

diff --git a/examples/simple-publisher-redis.py b/examples/simple-publisher-redis.py
@@ -9,12 +9,12 @@
 import random
 import secrets
 
-from callosum.pubsub import (
-    Publisher,
-)
 from callosum.lower.dispatch_redis import (
-    RedisStreamAddress,
     DispatchRedisTransport,
+    RedisStreamAddress,
+)
+from callosum.pubsub import (
+    Publisher,
 )
 
 

diff --git a/examples/simple-server-redis.py b/examples/simple-server-redis.py
@@ -4,11 +4,11 @@
 import signal
 import time
 
-from callosum.rpc import Peer
 from callosum.lower.rpc_redis import (
     RedisStreamAddress,
     RPCRedisTransport,
 )
+from callosum.rpc import Peer
 
 
 async def handle_echo(request):

diff --git a/examples/simple-server-thrift.py b/examples/simple-server-thrift.py
@@ -2,12 +2,12 @@
 import pathlib
 import signal
 
-from callosum.rpc import Peer
-from callosum.serialize import noop_serializer, noop_deserializer
-from callosum.lower.zeromq import ZeroMQAddress, ZeroMQRPCTransport
-from callosum.upper.thrift import ThriftServerAdaptor
 import thriftpy2 as thriftpy
 
+from callosum.lower.zeromq import ZeroMQAddress, ZeroMQRPCTransport
+from callosum.rpc import Peer
+from callosum.serialize import noop_deserializer, noop_serializer
+from callosum.upper.thrift import ThriftServerAdaptor
 
 simple_thrift = thriftpy.load(
     str(pathlib.Path(__file__).parent / "simple.thrift"), module_name="simple_thrift"

diff --git a/examples/simple-server.py b/examples/simple-server.py
@@ -6,14 +6,14 @@
 from typing import Mapping, Type
 
 import click
-from callosum.rpc import Peer
+
+from callosum.lower.zeromq import ZeroMQAddress, ZeroMQRPCTransport
 from callosum.ordering import (
     AbstractAsyncScheduler,
     ExitOrderedAsyncScheduler,
     KeySerializedAsyncScheduler,
 )
-from callosum.lower.zeromq import ZeroMQAddress, ZeroMQRPCTransport
-
+from callosum.rpc import Peer
 
 scheduler_types: Mapping[str, Type[AbstractAsyncScheduler]] = {
     "key-serialized": KeySerializedAsyncScheduler,