File tree Expand file tree Collapse file tree 7 files changed +9
-10
lines changed Expand file tree Collapse file tree 7 files changed +9
-10
lines changed File renamed without changes.
Original file line number Diff line number Diff line change 1
1
import pytest
2
2
3
+ from dagster_sqlmesh .conftest import SQLMeshTestContext
3
4
from dagster_sqlmesh .controller .base import PlanOptions
4
5
from dagster_sqlmesh .utils import snapshot_id_to_model_name
5
- from tests .conftest import SQLMeshTestContext
6
6
7
7
8
8
def test_given_basic_plan_when_building_then_returns_expected_plan_properties (
Original file line number Diff line number Diff line change 4
4
import pytest
5
5
from pandas .testing import assert_frame_equal
6
6
7
+ from dagster_sqlmesh .conftest import SQLMeshTestContext
7
8
from dagster_sqlmesh .controller .base import PlanOptions
8
- from tests .conftest import SQLMeshTestContext
9
9
10
10
logger = logging .getLogger (__name__ )
11
11
Original file line number Diff line number Diff line change 2
2
3
3
import pytest
4
4
5
+ from dagster_sqlmesh .conftest import SQLMeshTestContext
5
6
from dagster_sqlmesh .controller .base import PlanOptions , RunOptions
6
- from tests .conftest import SQLMeshTestContext
7
7
8
8
logger = logging .getLogger (__name__ )
9
9
Original file line number Diff line number Diff line change 2
2
3
3
import pytest
4
4
5
+ from dagster_sqlmesh .conftest import SQLMeshTestContext
5
6
from dagster_sqlmesh .controller .base import PlanOptions , RunOptions
6
- from tests .conftest import SQLMeshTestContext
7
7
8
8
logger = logging .getLogger (__name__ )
9
9
@@ -38,7 +38,6 @@ def test_given_seed_model_when_selected_then_only_builds_seed(
38
38
run_options = RunOptions (
39
39
execution_time = "2024-07-15" ,
40
40
),
41
-
42
41
select_models = ["sqlmesh_example.seed_model_1" ],
43
42
)
44
43
Original file line number Diff line number Diff line change 3
3
import polars
4
4
import pytest
5
5
6
+ from dagster_sqlmesh .conftest import SQLMeshTestContext
6
7
from dagster_sqlmesh .controller .base import PlanOptions , RunOptions
7
- from tests .conftest import SQLMeshTestContext
8
8
9
9
logger = logging .getLogger (__name__ )
10
10
@@ -19,7 +19,7 @@ def test_basic_sqlmesh_context(sample_sqlmesh_test_context: SQLMeshTestContext):
19
19
SELECT COUNT(*) as items FROM sqlmesh_example__dev.staging_model_1
20
20
"""
21
21
)
22
- assert staging_model_count [0 ][0 ] == 7
22
+ assert staging_model_count [0 ][0 ] == 8
23
23
24
24
25
25
def test_sqlmesh_context (sample_sqlmesh_test_context : SQLMeshTestContext ):
@@ -61,7 +61,7 @@ def test_sqlmesh_context(sample_sqlmesh_test_context: SQLMeshTestContext):
61
61
SELECT COUNT(*) FROM sqlmesh_example__dev.staging_model_1
62
62
"""
63
63
)
64
- assert staging_model_count [0 ][0 ] == 7
64
+ assert staging_model_count [0 ][0 ] == 8
65
65
66
66
test_source_model_count = sample_sqlmesh_test_context .query (
67
67
"""
@@ -96,7 +96,7 @@ def test_sqlmesh_context(sample_sqlmesh_test_context: SQLMeshTestContext):
96
96
SELECT COUNT(*) FROM sqlmesh_example__dev.staging_model_1
97
97
"""
98
98
)
99
- assert staging_model_count [0 ][0 ] == 7
99
+ assert staging_model_count [0 ][0 ] == 8
100
100
101
101
test_source_model_count = sample_sqlmesh_test_context .query (
102
102
"""
Original file line number Diff line number Diff line change 1
1
from dagster_sqlmesh .asset import (
2
2
SQLMeshDagsterTranslator ,
3
3
)
4
- from tests .conftest import SQLMeshTestContext
4
+ from dagster_sqlmesh .conftest import SQLMeshTestContext
5
5
6
6
7
7
def test_sqlmesh_context_to_asset_outs (sample_sqlmesh_test_context : SQLMeshTestContext ):
You can’t perform that action at this time.
0 commit comments