Skip to content

Commit 390a8ec

Browse files
committed
fix s3 path
1 parent 1d4874c commit 390a8ec

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

python/hsfs/core/arrow_flight_client.py

+2
Original file line numberDiff line numberDiff line change
@@ -577,6 +577,8 @@ def _serialize_featuregroup_connector(fg, query, on_demand_fg_aliases):
577577
connector["time_travel_type"] = "delta"
578578
connector["type"] = fg.storage_connector.type
579579
connector["options"] = fg.storage_connector.connector_options()
580+
if fg.storage_connector.type == StorageConnector.S3:
581+
connector["path"] = fg.location
580582
connector["query"] = ""
581583
if query._left_feature_group == fg:
582584
connector["filters"] = _serialize_filter_expression(

python/hsfs/storage_connector.py

-1
Original file line numberDiff line numberDiff line change
@@ -375,7 +375,6 @@ def connector_options(self) -> Dict[str, Any]:
375375
"access_key": self.access_key,
376376
"secret_key": self.secret_key,
377377
"session_token": self.session_token,
378-
"path": self.path,
379378
"region": self.region,
380379
}
381380

0 commit comments

Comments
 (0)