1
0
mirror of synced 2025-12-26 05:05:18 -05:00

raise FAIL after stream-read exception (#2695)

This commit is contained in:
Nathan Nowack
2021-04-01 15:47:14 -06:00
committed by GitHub
parent da68a24954
commit 317e8b44ff

View File

@@ -86,9 +86,10 @@ class BaseSource(Source):
for configured_stream in catalog.streams:
try:
yield from self._read_stream(logger=logger, client=client, configured_stream=configured_stream, state=total_state)
# TODO: test stream fail
except Exception:
logger.exception(f"Encountered an exception while reading stream {self.name}")
raise
logger.info(f"Finished syncing {self.name}")