black and flake8 fixes

Signed-off-by: Chester Ong <chester.ong.ch@gmail.com>
feast-dev · franciscojavierarceo · Feb 10, 2024 · Feb 5, 2024 · Feb 7, 2024 · Feb 7, 2024
commit 3ceaa0620902054ec74b9b64c6df5f68ce42c47e
@@ -11,7 +11,6 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
-import abc
 import enum
 import warnings
 from abc import ABC, abstractmethod

@@ -68,7 +68,9 @@ def __init__(
         # data_source type has been checked to be an instance of KafkaSource.
         self.data_source: KafkaSource = self.data_source  # type: ignore
 
-    def ingest_stream_feature_view(self, to: PushMode = PushMode.ONLINE) -> StreamingQuery:
+    def ingest_stream_feature_view(
+        self, to: PushMode = PushMode.ONLINE
+    ) -> StreamingQuery:
         ingested_stream_df = self._ingest_stream_data()
         transformed_df = self._construct_transformation_plan(ingested_stream_df)
         online_store_query = self._write_stream_data(transformed_df, to)

@@ -12,7 +12,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 import warnings
-from abc import ABC, abstractmethod
+from abc import ABC
 from datetime import datetime
 from pathlib import Path
 from typing import TYPE_CHECKING, Any, Callable, List, Optional, Union

@@ -45,7 +45,11 @@
 
 
 class GetSnowflakeConnection:
-    def __init__(self, config: SnowflakeOfflineStoreConfig | SnowflakeOnlineStoreConfig, autocommit=True):
+    def __init__(
+        self,
+        config: SnowflakeOfflineStoreConfig | SnowflakeOnlineStoreConfig,
+        autocommit=True,
+    ):
         self.config = config
         self.autocommit = autocommit
 

@@ -114,7 +114,10 @@ def feast_value_type_to_pandas_type(value_type: ValueType) -> Any:
 
 
 def python_type_to_feast_value_type(
-    name: str, value: Optional[Any] = None, recurse: bool = True, type_name: Optional[str] = None
+    name: str,
+    value: Optional[Any] = None,
+    recurse: bool = True,
+    type_name: Optional[str] = None,
 ) -> ValueType:
     """
     Finds the equivalent Feast Value Type for a Python value. Both native