Skip to content

Commit 5503c47

Browse files
committed
Use rekcurd_grpc_version as str
1 parent b6055b2 commit 5503c47

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

rekcurd_client/core/rekcurd_worker_client.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ class RekcurdWorkerClient:
4343

4444
def __init__(self, host: str = None, port: int = None,
4545
application_name: str = None, service_level: str = None,
46-
rekcurd_grpc_version: int = None):
46+
rekcurd_grpc_version: str = None):
4747
self._logger = JsonSystemLogger()
4848

4949
_host = "127.0.0.1"
@@ -52,13 +52,13 @@ def __init__(self, host: str = None, port: int = None,
5252
port = int(port or _port)
5353

5454
if rekcurd_grpc_version is None:
55-
v_str = rekcurd_pb2.DESCRIPTOR.GetOptions().Extensions[rekcurd_pb2.rekcurd_grpc_proto_version]
55+
rekcurd_grpc_version = rekcurd_pb2.DESCRIPTOR.GetOptions().Extensions[rekcurd_pb2.rekcurd_grpc_proto_version]
5656
else:
57-
v_str = rekcurd_pb2.EnumVersionInfo.Name(rekcurd_grpc_version)
57+
rekcurd_pb2.EnumVersionInfo.Value(rekcurd_grpc_version)
5858

5959
self.__metadata = [('x-rekcurd-application-name', application_name),
6060
('x-rekcurd-sevice-level', service_level),
61-
('x-rekcurd-grpc-version', v_str)]
61+
('x-rekcurd-grpc-version', rekcurd_grpc_version)]
6262

6363
channel = grpc.insecure_channel("{}:{}".format(host, port))
6464
self.stub = rekcurd_pb2_grpc.RekcurdWorkerStub(channel)

0 commit comments

Comments
 (0)