Skip to content

Commit 0d54352

Browse files
fix(ge-profiler): catch TimeoutError (#12855)
1 parent 86f4b80 commit 0d54352

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

metadata-ingestion/src/datahub/ingestion/source/unity/ge_profiler.py

+2-1
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
1+
import concurrent.futures
12
import logging
23
from concurrent.futures import ThreadPoolExecutor, as_completed
34
from dataclasses import dataclass, field
@@ -91,7 +92,7 @@ def get_workunits(self, tables: List[Table]) -> Iterable[MetadataWorkUnit]:
9192
profile_requests.append(profile_request)
9293
if i > 0 and i % 100 == 0:
9394
logger.info(f"Finished table-level profiling for {i} tables")
94-
except TimeoutError:
95+
except (TimeoutError, concurrent.futures.TimeoutError):
9596
logger.warning("Timed out waiting to complete table-level profiling.")
9697

9798
if len(profile_requests) == 0:

0 commit comments

Comments
 (0)