We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 75cb696 commit f9e566fCopy full SHA for f9e566f
1 file changed
sqlmesh/core/loader.py
@@ -11,6 +11,7 @@
11
from dataclasses import dataclass
12
from pathlib import Path
13
from pydantic import ValidationError
14
+import concurrent.futures
15
16
from sqlglot.errors import SqlglotError
17
from sqlglot import exp
@@ -547,9 +548,10 @@ def _load_sql_models(
547
548
max_workers=c.MAX_FORK_WORKERS,
549
) as pool:
550
futures_to_paths = {pool.submit(load_sql_models, path): path for path in paths}
- for fut, path in futures_to_paths.items():
551
+ for future in concurrent.futures.as_completed(futures_to_paths):
552
+ path = futures_to_paths[future]
553
try:
- _, loaded = fut.result()
554
+ _, loaded = future.result()
555
if loaded:
556
for model in loaded:
557
if model.enabled:
0 commit comments