Skip to content

Commit

Permalink
Fix style issue
Browse files Browse the repository at this point in the history
  • Loading branch information
aaron-ai committed Jun 8, 2023
1 parent 07f4545 commit edfce65
Show file tree
Hide file tree
Showing 5 changed files with 11 additions and 19 deletions.
5 changes: 3 additions & 2 deletions python/rocketmq/client_id_encoder.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,10 +13,11 @@
# See the License for the specific language governing permissions and
# limitations under the License.

import threading
import socket
import os
import socket
import threading
import time

import rocketmq.utils


Expand Down
7 changes: 4 additions & 3 deletions python/rocketmq/client_manager.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,11 +13,12 @@
# See the License for the specific language governing permissions and
# limitations under the License.

from rocketmq.rpc_client import Endpoints, RpcClient
from rocketmq.client import Client
from protocol import service_pb2
import threading

from protocol import service_pb2
from rocketmq.client import Client
from rocketmq.rpc_client import Endpoints, RpcClient


class ClientManager:
def __init__(self, client: Client):
Expand Down
4 changes: 0 additions & 4 deletions python/rocketmq/message.py
Original file line number Diff line number Diff line change
Expand Up @@ -116,10 +116,6 @@ def properties(self):
def tag(self):
return self.__tag

@property
def keys(self):
return self.__keys

@property
def message_group(self):
return self.__message_group
Expand Down
5 changes: 3 additions & 2 deletions python/rocketmq/signature.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,10 +13,11 @@
# See the License for the specific language governing permissions and
# limitations under the License.

from rocketmq.client_config import ClientConfig
import uuid
import datetime
import importlib.metadata
import uuid

from rocketmq.client_config import ClientConfig
from rocketmq.utils import sign


Expand Down
9 changes: 1 addition & 8 deletions python/rocketmq/utils.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,16 +13,9 @@
# See the License for the specific language governing permissions and
# limitations under the License.

import hmac
import hashlib
import hmac

from apscheduler.executors.pool import ThreadPoolExecutor, ProcessPoolExecutor
from multiprocessing import cpu_count

scheduler_executors = {
'default': ThreadPoolExecutor(2 * cpu_count()),
# 'processpool': ProcessPoolExecutor(5)
}

def number_to_base(number, base):
alphabet = "0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ"
Expand Down

0 comments on commit edfce65

Please sign in to comment.