|
11 | 11 | # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
12 | 12 | # See the License for the specific language governing permissions and |
13 | 13 | # limitations under the License. |
14 | | - |
15 | | - |
16 | 14 | import datetime |
17 | 15 | import logging |
18 | 16 | import multiprocessing |
|
29 | 27 | import grpc |
30 | 28 | import pandas as pd |
31 | 29 | import pyarrow as pa |
32 | | -import pyarrow.parquet as pq |
33 | 30 | from google.protobuf.timestamp_pb2 import Timestamp |
34 | | -from tensorflow_metadata.proto.v0 import statistics_pb2 |
| 31 | +from pyarrow import parquet as pq |
35 | 32 |
|
36 | | -import feast.grpc.auth as feast_auth |
37 | 33 | from feast.config import Config |
38 | 34 | from feast.constants import ( |
39 | 35 | CONFIG_CORE_ENABLE_AUTH_KEY, |
|
72 | 68 | from feast.core.FeatureSet_pb2 import FeatureSetStatus |
73 | 69 | from feast.feature import Feature, FeatureRef |
74 | 70 | from feast.feature_set import Entity, FeatureSet, FeatureSetRef |
| 71 | +from feast.grpc import auth as feast_auth |
75 | 72 | from feast.grpc.grpc import create_grpc_channel |
76 | 73 | from feast.job import IngestJob, RetrievalJob |
77 | 74 | from feast.loaders.abstract_producer import get_producer |
|
91 | 88 | from feast.serving.ServingService_pb2_grpc import ServingServiceStub |
92 | 89 | from feast.type_map import _python_value_to_proto_value, python_type_to_feast_value_type |
93 | 90 | from feast.types.Value_pb2 import Value as Value |
| 91 | +from tensorflow_metadata.proto.v0 import statistics_pb2 |
94 | 92 |
|
95 | 93 | _logger = logging.getLogger(__name__) |
96 | 94 |
|
|
0 commit comments