File tree Expand file tree Collapse file tree 1 file changed +5
-2
lines changed Expand file tree Collapse file tree 1 file changed +5
-2
lines changed Original file line number Diff line number Diff line change @@ -281,6 +281,9 @@ def run(
281
281
plan_options = plan_options or {}
282
282
run_options = run_options or {}
283
283
284
+ if translator is None :
285
+ translator = SQLMeshDagsterTranslator ()
286
+
284
287
logger = context .log
285
288
286
289
controller = self .get_controller (logger , translator )
@@ -299,7 +302,7 @@ def run(
299
302
models_map = {}
300
303
for key , model in models .items ():
301
304
if (
302
- self . translator .get_asset_key_str (model .name )
305
+ translator .get_sqlmesh_model_name_from_key_str (model .name )
303
306
in context .selected_output_names
304
307
):
305
308
models_map [key ] = model
@@ -317,7 +320,7 @@ def run(
317
320
318
321
event_handler = DagsterSQLMeshEventHandler (
319
322
context = context , models_map = models_map , dag = dag ,
320
- prefix = "sqlmesh: " , translator = self . translator
323
+ prefix = "sqlmesh: " , translator = translator
321
324
)
322
325
323
326
for event in mesh .plan_and_run (
You can’t perform that action at this time.
0 commit comments