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(
281281 plan_options = plan_options or {}
282282 run_options = run_options or {}
283283
284+ if translator is None :
285+ translator = SQLMeshDagsterTranslator ()
286+
284287 logger = context .log
285288
286289 controller = self .get_controller (logger , translator )
@@ -299,7 +302,7 @@ def run(
299302 models_map = {}
300303 for key , model in models .items ():
301304 if (
302- self . translator .get_asset_key_str (model .name )
305+ translator .get_sqlmesh_model_name_from_key_str (model .name )
303306 in context .selected_output_names
304307 ):
305308 models_map [key ] = model
@@ -317,7 +320,7 @@ def run(
317320
318321 event_handler = DagsterSQLMeshEventHandler (
319322 context = context , models_map = models_map , dag = dag ,
320- prefix = "sqlmesh: " , translator = self . translator
323+ prefix = "sqlmesh: " , translator = translator
321324 )
322325
323326 for event in mesh .plan_and_run (
You can’t perform that action at this time.
0 commit comments