|
40 | 40 | import time |
41 | 41 | import traceback |
42 | 42 | import typing as t |
43 | | -from datetime import datetime |
44 | 43 | from functools import cached_property |
45 | 44 | from io import StringIO |
46 | 45 | from itertools import chain |
47 | 46 | from pathlib import Path |
48 | 47 | from shutil import rmtree |
49 | 48 | from types import MappingProxyType |
| 49 | +from datetime import datetime |
50 | 50 |
|
51 | 51 | from sqlglot import Dialect, exp |
52 | 52 | from sqlglot.helper import first |
|
63 | 63 | ) |
64 | 64 | from sqlmesh.core.config.connection import ConnectionConfig |
65 | 65 | from sqlmesh.core.config.loader import C |
66 | | -from sqlmesh.core.config.model import ModelDefaultsConfig |
67 | 66 | from sqlmesh.core.config.root import RegexKeyDict |
68 | 67 | from sqlmesh.core.console import get_console |
69 | 68 | from sqlmesh.core.context_diff import ContextDiff |
|
77 | 76 | ) |
78 | 77 | from sqlmesh.core.engine_adapter import EngineAdapter |
79 | 78 | from sqlmesh.core.environment import Environment, EnvironmentNamingInfo, EnvironmentStatements |
80 | | -from sqlmesh.core.janitor import cleanup_expired_views, delete_expired_snapshots |
| 79 | +from sqlmesh.core.loader import Loader |
81 | 80 | from sqlmesh.core.linter.definition import AnnotatedRuleViolation, Linter |
82 | 81 | from sqlmesh.core.linter.rules import BUILTIN_RULES |
83 | | -from sqlmesh.core.loader import Loader |
84 | 82 | from sqlmesh.core.macros import ExecutableOrMacro, macro |
85 | 83 | from sqlmesh.core.metric import Metric, rewrite |
86 | 84 | from sqlmesh.core.model import Model, update_model_schemas |
| 85 | +from sqlmesh.core.config.model import ModelDefaultsConfig |
87 | 86 | from sqlmesh.core.notification_target import ( |
88 | 87 | NotificationEvent, |
89 | 88 | NotificationTarget, |
90 | 89 | NotificationTargetManager, |
91 | 90 | ) |
92 | | -from sqlmesh.core.plan import Plan, PlanBuilder, PlanExplainer, SnapshotIntervals |
| 91 | +from sqlmesh.core.plan import Plan, PlanBuilder, SnapshotIntervals, PlanExplainer |
93 | 92 | from sqlmesh.core.plan.definition import UserProvidedFlags |
94 | 93 | from sqlmesh.core.reference import ReferenceGraph |
95 | | -from sqlmesh.core.scheduler import CompletionStatus, Scheduler |
| 94 | +from sqlmesh.core.scheduler import Scheduler, CompletionStatus |
96 | 95 | from sqlmesh.core.schema_loader import create_external_models_file |
97 | | -from sqlmesh.core.selector import NativeSelector, Selector |
| 96 | +from sqlmesh.core.selector import Selector, NativeSelector |
98 | 97 | from sqlmesh.core.snapshot import ( |
99 | 98 | DeployabilityIndex, |
100 | 99 | Snapshot, |
|
109 | 108 | StateReader, |
110 | 109 | StateSync, |
111 | 110 | ) |
| 111 | +from sqlmesh.core.janitor import cleanup_expired_views, delete_expired_snapshots |
112 | 112 | from sqlmesh.core.table_diff import TableDiff |
113 | 113 | from sqlmesh.core.test import ( |
114 | | - ModelTestMetadata, |
115 | 114 | ModelTextTestResult, |
116 | | - filter_tests_by_patterns, |
| 115 | + ModelTestMetadata, |
117 | 116 | generate_test, |
118 | 117 | run_tests, |
| 118 | + filter_tests_by_patterns, |
119 | 119 | ) |
120 | 120 | from sqlmesh.core.user import User |
121 | 121 | from sqlmesh.utils import UniqueKeyDict, Verbosity |
122 | 122 | from sqlmesh.utils.concurrency import concurrent_apply_to_values |
123 | | -from sqlmesh.utils.config import print_config |
124 | 123 | from sqlmesh.utils.dag import DAG |
125 | 124 | from sqlmesh.utils.date import ( |
126 | 125 | TimeLike, |
| 126 | + to_timestamp, |
127 | 127 | format_tz_datetime, |
128 | | - make_exclusive, |
129 | | - now, |
130 | 128 | now_timestamp, |
| 129 | + now, |
131 | 130 | to_datetime, |
132 | | - to_timestamp, |
| 131 | + make_exclusive, |
133 | 132 | ) |
134 | 133 | from sqlmesh.utils.errors import ( |
135 | 134 | CircuitBreakerError, |
136 | 135 | ConfigError, |
137 | | - LinterError, |
138 | 136 | PlanError, |
139 | 137 | SQLMeshError, |
140 | 138 | UncategorizedPlanError, |
| 139 | + LinterError, |
141 | 140 | ) |
| 141 | +from sqlmesh.utils.config import print_config |
142 | 142 | from sqlmesh.utils.jinja import JinjaMacroRegistry |
143 | 143 | from sqlmesh.utils.windows import IS_WINDOWS, fix_windows_path |
144 | 144 |
|
|
0 commit comments