Linting

dashboard/modules/event/event_agent.py

@@ -6,8 +6,6 @@
 import ray._private.utils as utils
 import ray.dashboard.utils as dashboard_utils
 import ray.dashboard.consts as dashboard_consts
-import ray.dashboard.utils as dashboard_utils
-import ray.dashboard.consts as dashboard_consts
 from ray.ray_constants import env_bool
 from ray.dashboard.utils import async_loop_forever, create_task
 from ray.dashboard.modules.event import event_consts

python/ray/internal/internal_api.py

@@ -1,5 +1,3 @@
-import os
-
 import ray
 import ray._private.services as services
 import ray.worker
@@ -44,7 +42,6 @@ def memory_summary(address=None,
 def get_store_stats(state, node_manager_address=None, node_manager_port=None):
  """Returns a formatted string describing memory usage in the cluster."""
 
- import grpc
  from ray.core.generated import node_manager_pb2
  from ray.core.generated import node_manager_pb2_grpc
 
@@ -84,7 +81,6 @@ def node_stats(node_manager_address=None,
  include_memory_info=True):
  """Returns NodeStats object describing memory usage in the cluster."""
 
- import grpc
  from ray.core.generated import node_manager_pb2
  from ray.core.generated import node_manager_pb2_grpc
 

python/ray/scripts/scripts.py

@@ -16,7 +16,6 @@
 
 import ray
 import psutil
-import grpc
 import ray._private.services as services
 import ray.ray_constants as ray_constants
 import ray._private.utils

python/ray/tests/test_multi_tenancy.py

@@ -3,7 +3,6 @@
 import sys
 import time
 
-import grpc
 import pytest
 import numpy as np
 

python/ray/util/client/server/proxier.py

@@ -28,7 +28,8 @@
 from ray._private.parameter import RayParams
 from ray._private.runtime_env import RuntimeEnvContext
 from ray._private.services import ProcessInfo, start_ray_client_server
-from ray._private.utils import detect_fate_sharing_support, add_port_to_grpc_server
+from ray._private.utils import (detect_fate_sharing_support,
+ add_port_to_grpc_server)
 
 # Import psutil after ray so the packaged version is used.
 import psutil

python/ray/util/client/server/server.py

@@ -1,5 +1,4 @@
 import logging
-import os
 from concurrent import futures
 import grpc
 import base64

python/ray/util/client/worker.py

@@ -106,8 +106,8 @@ def __init__(
 
  # TODO tidy this up
  if self._secure and _credentials is None:
- server_cert_chain, private_key, ca_cert = ray._private.utils.load_certs_from_env(
- )
+ server_cert_chain, private_key, ca_cert = ray._private.utils\
+  .load_certs_from_env()
  _credentials = grpc.ssl_channel_credentials(
  certificate_chain=server_cert_chain,
  private_key=private_key,