From 4455f539fab8fbf0343b7678a1b1182ac7afb2a3 Mon Sep 17 00:00:00 2001
From: "peng.xu" <peng.xu@zilliz.com>
Date: Mon, 14 Oct 2019 13:54:37 +0800
Subject: [PATCH] code refactor for unused import

---
 mishards/connections.py     | 2 --
 mishards/models.py          | 2 +-
 mishards/server.py          | 2 --
 mishards/service_handler.py | 1 -
 sd/kubernetes_provider.py   | 5 ++---
 5 files changed, 3 insertions(+), 9 deletions(-)

diff --git a/mishards/connections.py b/mishards/connections.py
index ccd8e7e81b..22263e9e7e 100644
--- a/mishards/connections.py
+++ b/mishards/connections.py
@@ -1,8 +1,6 @@
 import logging
 import threading
-import socket
 from functools import wraps
-from contextlib import contextmanager
 from milvus import Milvus
 
 from mishards import (settings, exceptions)
diff --git a/mishards/models.py b/mishards/models.py
index 54cf5f8ed9..4b6c8f9ef4 100644
--- a/mishards/models.py
+++ b/mishards/models.py
@@ -1,6 +1,6 @@
 import logging
 from sqlalchemy import (Integer, Boolean, Text,
-                        String, BigInteger, func, and_, or_,
+                        String, BigInteger, and_, or_,
                         Column)
 from sqlalchemy.orm import relationship, backref
 
diff --git a/mishards/server.py b/mishards/server.py
index 032d101cba..feb2176e86 100644
--- a/mishards/server.py
+++ b/mishards/server.py
@@ -7,8 +7,6 @@ from urllib.parse import urlparse
 from functools import wraps
 from concurrent import futures
 from grpc._cython import cygrpc
-from grpc._channel import _Rendezvous, _UnaryUnaryMultiCallable
-from jaeger_client import Config
 from milvus.grpc_gen.milvus_pb2_grpc import add_MilvusServiceServicer_to_server
 from mishards.grpc_utils import is_grpc_method
 from mishards.service_handler import ServiceHandler
diff --git a/mishards/service_handler.py b/mishards/service_handler.py
index 2a1e0eef02..9d851ecfcb 100644
--- a/mishards/service_handler.py
+++ b/mishards/service_handler.py
@@ -1,7 +1,6 @@
 import logging
 import time
 import datetime
-from contextlib import contextmanager
 from collections import defaultdict
 
 from sqlalchemy import and_
diff --git a/sd/kubernetes_provider.py b/sd/kubernetes_provider.py
index 924f1fc8a4..8ee1588ec4 100644
--- a/sd/kubernetes_provider.py
+++ b/sd/kubernetes_provider.py
@@ -9,7 +9,6 @@ import time
 import copy
 import threading
 import queue
-from functools import wraps
 from kubernetes import client, config, watch
 
 from utils import singleton
@@ -17,7 +16,7 @@ from sd import ProviderManager
 
 logger = logging.getLogger(__name__)
 
-incluster_namespace_path = '/var/run/secrets/kubernetes.io/serviceaccount/namespace'
+INCLUSTER_NAMESPACE_PATH = '/var/run/secrets/kubernetes.io/serviceaccount/namespace'
 
 
 class K8SMixin:
@@ -27,7 +26,7 @@ class K8SMixin:
         self.kwargs = kwargs
         self.v1 = kwargs.get('v1', None)
         if not self.namespace:
-            self.namespace = open(incluster_namespace_path).read()
+            self.namespace = open(INCLUSTER_NAMESPACE_PATH).read()
 
         if not self.v1:
             config.load_incluster_config() if self.in_cluster else config.load_kube_config()