Skip to content

Commit

Permalink
Since server is already module name, rename the variable (apache#185)
Browse files Browse the repository at this point in the history
  • Loading branch information
srkukarni authored and sijie committed Mar 4, 2018
1 parent 10e45d6 commit a954d96
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions pulsar-functions/runtime/src/main/python/server.py
Original file line number Diff line number Diff line change
Expand Up @@ -62,10 +62,10 @@ def GetAndResetMetrics(self, request, context):


def serve(port, pyinstance):
server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
server_instance = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
InstanceCommunication_pb2_grpc.add_InstanceControlServicer_to_server(
InstanceCommunicationServicer(pyinstance), server)
server.add_insecure_port('[::]:%d' % port)
InstanceCommunicationServicer(pyinstance), server_instance)
server_instance.add_insecure_port('[::]:%d' % port)
Log.info("Serving InstanceCommunication on port %d" % int(port))
server.start()
return server
server_instance.start()
return server_instance

0 comments on commit a954d96

Please sign in to comment.