File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -22,7 +22,7 @@ def sqlmesh_assets(
22
22
config : SQLMeshContextConfig ,
23
23
context_factory : ContextFactory [ContextCls ] = lambda ** kwargs : Context (** kwargs ),
24
24
name : str | None = None ,
25
- dagster_sqlmesh_translator : SQLMeshDagsterTranslator = SQLMeshDagsterTranslator () ,
25
+ dagster_sqlmesh_translator : SQLMeshDagsterTranslator | None = None ,
26
26
compute_kind : str = "sqlmesh" ,
27
27
op_tags : t .Mapping [str , t .Any ] | None = None ,
28
28
required_resource_keys : set [str ] | None = None ,
@@ -31,7 +31,8 @@ def sqlmesh_assets(
31
31
enabled_subsetting : bool = False ,
32
32
) -> t .Callable [[t .Callable [..., t .Any ]], AssetsDefinition ]:
33
33
controller = DagsterSQLMeshController .setup_with_config (config = config , context_factory = context_factory )
34
-
34
+ if not dagster_sqlmesh_translator :
35
+ dagster_sqlmesh_translator = SQLMeshDagsterTranslator ()
35
36
conversion = controller .to_asset_outs (environment , translator = dagster_sqlmesh_translator )
36
37
37
38
return multi_asset (
You can’t perform that action at this time.
0 commit comments