File tree Expand file tree Collapse file tree 5 files changed +12
-15
lines changed Expand file tree Collapse file tree 5 files changed +12
-15
lines changed Original file line number Diff line number Diff line change 4
4
from dagster import AssetsDefinition , RetryPolicy , multi_asset
5
5
from sqlmesh import Context
6
6
7
+ from dagster_sqlmesh .config import SQLMeshContextConfig
7
8
from dagster_sqlmesh .controller import (
8
9
ContextCls ,
9
10
ContextFactory ,
10
11
DagsterSQLMeshController ,
11
12
)
12
13
from dagster_sqlmesh .translator import SQLMeshDagsterTranslator
13
14
14
- from .config import SQLMeshContextConfig
15
-
16
15
logger = logging .getLogger (__name__ )
17
16
18
17
Original file line number Diff line number Diff line change 13
13
from sqlmesh .utils .dag import DAG
14
14
from sqlmesh .utils .date import TimeLike
15
15
16
- from . .config import SQLMeshContextConfig
17
- from . .console import (
16
+ from dagster_sqlmesh .config import SQLMeshContextConfig
17
+ from dagster_sqlmesh .console import (
18
18
ConsoleEvent ,
19
19
ConsoleEventHandler ,
20
20
ConsoleException ,
21
21
EventConsole ,
22
22
Plan ,
23
23
SnapshotCategorizer ,
24
24
)
25
- from . .events import ConsoleGenerator
25
+ from dagster_sqlmesh .events import ConsoleGenerator
26
26
27
27
logger = logging .getLogger (__name__ )
28
28
Original file line number Diff line number Diff line change 5
5
from dagster import AssetDep , AssetKey , AssetOut
6
6
from dagster ._core .definitions .asset_dep import CoercibleToAssetDep
7
7
8
+ from dagster_sqlmesh .controller .base import ContextCls , SQLMeshController
9
+ from dagster_sqlmesh .translator import SQLMeshDagsterTranslator
10
+ from dagster_sqlmesh .types import SQLMeshModelDep , SQLMeshMultiAssetOptions
8
11
from dagster_sqlmesh .utils import get_asset_key_str
9
12
10
- from ..translator import SQLMeshDagsterTranslator
11
- from ..types import SQLMeshModelDep , SQLMeshMultiAssetOptions
12
- from .base import ContextCls , SQLMeshController
13
-
14
13
logger = logging .getLogger (__name__ )
15
14
16
15
Original file line number Diff line number Diff line change 15
15
from sqlmesh .utils .date import TimeLike
16
16
from sqlmesh .utils .errors import SQLMeshError
17
17
18
+ from dagster_sqlmesh import console
19
+ from dagster_sqlmesh .config import SQLMeshContextConfig
20
+ from dagster_sqlmesh .controller import PlanOptions , RunOptions
18
21
from dagster_sqlmesh .controller .base import (
19
22
DEFAULT_CONTEXT_FACTORY ,
20
23
ContextCls ,
21
24
ContextFactory ,
22
25
)
26
+ from dagster_sqlmesh .controller .dagster import DagsterSQLMeshController
23
27
from dagster_sqlmesh .utils import get_asset_key_str
24
28
25
- from . import console
26
- from .config import SQLMeshContextConfig
27
- from .controller import PlanOptions , RunOptions
28
- from .controller .dagster import DagsterSQLMeshController
29
-
30
29
31
30
class MaterializationTracker :
32
31
"""Tracks sqlmesh materializations and notifies dagster in the correct
Original file line number Diff line number Diff line change 2
2
3
3
import polars
4
4
5
- from .testing import SQLMeshTestContext
5
+ from dagster_sqlmesh .testing import SQLMeshTestContext
6
6
7
7
logger = logging .getLogger (__name__ )
8
8
You can’t perform that action at this time.
0 commit comments