We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent bde191f commit d3aa98cCopy full SHA for d3aa98c
src/sagemaker/feature_store/feature_group.py
@@ -421,12 +421,10 @@ def _run_multi_threaded(
421
failed_indices = list()
422
for future in as_completed(futures, timeout=timeout):
423
start, end = futures[future]
424
- result = future.result()
425
- if result:
426
- logger.error("Failed to ingest row %d to %d", start, end)
427
- else:
+ failed_rows = future.result()
+ if not failed_rows:
428
logger.info("Successfully ingested row %d to %d", start, end)
429
- failed_indices += result
+ failed_indices += failed_rows
430
431
executor.shutdown(wait=False)
432
0 commit comments