Skip to content

Commit 34cabfb

Browse files
ElliotNguyen68ElliotNguyen68
authored
fix: Raise error when not able read of file source spark source (#4005)
fix: raise error when not able to read path sparksource Signed-off-by: tanlocnguyen <[email protected]> Co-authored-by: tanlocnguyen <[email protected]>
1 parent 5561b30 commit 34cabfb

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

  • sdk/python/feast/infra/offline_stores/contrib/spark_offline_store

‎sdk/python/feast/infra/offline_stores/contrib/spark_offline_store/spark_source.py‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88

99
from feast import flags_helper
1010
from feast.data_source import DataSource
11-
from feast.errors import DataSourceNoNameException
11+
from feast.errors import DataSourceNoNameException, DataSourceNotFoundException
1212
from feast.infra.offline_stores.offline_utils import get_temp_entity_table_name
1313
from feast.protos.feast.core.DataSource_pb2 import DataSource as DataSourceProto
1414
from feast.protos.feast.core.SavedDataset_pb2 import (
@@ -179,6 +179,7 @@ def get_table_query_string(self) -> str:
179179
logger.exception(
180180
"Spark read of file source failed.\n" + traceback.format_exc()
181181
)
182+
raise DataSourceNotFoundException(self.path)
182183
tmp_table_name = get_temp_entity_table_name()
183184
df.createOrReplaceTempView(tmp_table_name)
184185

0 commit comments

Comments
 (0)