Francesco Capuano commited on
Commit
78df986
·
1 Parent(s): 546bd37

fix: ports ports ports

Browse files
Dockerfile CHANGED
@@ -17,7 +17,7 @@ RUN pip install --no-cache-dir -e .
17
  RUN mkdir -p /app/logs && chmod 777 /app/logs
18
 
19
  # Expose the gRPC port
20
- EXPOSE 50051
21
 
22
  # Command to run the server
23
  CMD ["python", "lerobot/scripts/server/policy_server.py"]
 
17
  RUN mkdir -p /app/logs && chmod 777 /app/logs
18
 
19
  # Expose the gRPC port
20
+ EXPOSE 8080
21
 
22
  # Command to run the server
23
  CMD ["python", "lerobot/scripts/server/policy_server.py"]
lerobot/scripts/server/policy_server.py CHANGED
@@ -333,15 +333,16 @@ class PolicyServer(async_inference_pb2_grpc.AsyncInferenceServicer):
333
 
334
 
335
  def serve():
 
336
  # Create the server instance first
337
  policy_server = PolicyServer()
338
 
339
  # Setup and start gRPC server
340
  server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
341
  async_inference_pb2_grpc.add_AsyncInferenceServicer_to_server(policy_server, server)
342
- server.add_insecure_port("[::]:50051")
343
  server.start()
344
- logger.info("PolicyServer started on port 50051")
345
 
346
  try:
347
  # Use the running attribute to control server lifetime
 
333
 
334
 
335
  def serve():
336
+ PORT = 8080
337
  # Create the server instance first
338
  policy_server = PolicyServer()
339
 
340
  # Setup and start gRPC server
341
  server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
342
  async_inference_pb2_grpc.add_AsyncInferenceServicer_to_server(policy_server, server)
343
+ server.add_insecure_port(f"[::]:{PORT}")
344
  server.start()
345
+ logger.info(f"PolicyServer started on port {PORT}")
346
 
347
  try:
348
  # Use the running attribute to control server lifetime
lerobot/scripts/server/robot_client.py CHANGED
@@ -106,7 +106,7 @@ class RobotClient:
106
  ):
107
  # Use environment variable if server_address is not provided
108
  if server_address is None:
109
- server_address = os.getenv("SERVER_ADDRESS", "localhost:50051")
110
  logger.info(f"No server address provided, using default address: {server_address}")
111
 
112
  self.policy_config = TinyPolicyConfig(policy_type, pretrained_name_or_path, policy_device)
 
106
  ):
107
  # Use environment variable if server_address is not provided
108
  if server_address is None:
109
+ server_address = os.getenv("SERVER_ADDRESS", "localhost:8080")
110
  logger.info(f"No server address provided, using default address: {server_address}")
111
 
112
  self.policy_config = TinyPolicyConfig(policy_type, pretrained_name_or_path, policy_device)