Skip to content

Commit 113ff4f

Browse files
committed
fix wait function to handle more excpections
1 parent 1d84830 commit 113ff4f

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

src/sagemaker/feature_store/feature_group.py

+7-1
Original file line numberDiff line numberDiff line change
@@ -238,8 +238,11 @@ def wait(self, timeout=None):
238238
timeout (Union[int, float]): ``concurrent.futures.TimeoutError`` will be raised
239239
if timeout is reached.
240240
"""
241+
results = None
241242
try:
242-
results = self._async_result.get(timeout=timeout)
243+
self._async_result.wait(timeout=timeout)
244+
if self._async_result.ready() and self._async_result._success:
245+
results = self._async_result._value
243246
except KeyboardInterrupt as i:
244247
# terminate workers abruptly on keyboard interrupt.
245248
self._processing_pool.terminate()
@@ -251,6 +254,9 @@ def wait(self, timeout=None):
251254
self._processing_pool.close()
252255
self._processing_pool.clear()
253256

257+
if not results or results == NotImplementedError:
258+
return
259+
254260
self._failed_indices = [
255261
failed_index for failed_indices in results for failed_index in failed_indices
256262
]

0 commit comments

Comments
 (0)