Basil V
03/17/2020, 9:35 PMsome_alias = some_solid.alias('some_alias')
execute_solid(some_alias)
alex
03/17/2020, 9:48 PMBasil V
03/17/2020, 9:50 PMBasil V
03/17/2020, 9:51 PMalex
03/17/2020, 9:52 PMenviroment_dict
for execute_solid
Basil V
03/17/2020, 9:53 PMMODE = 'development'
mode_defs = {
'development': dev(),
'staging': staging(),
'production': prod(),
}
environment_dict = merge_yamls([
file_relative_path(__file__, '../environments/solids.yaml'),
file_relative_path(__file__, f'../../../utils/environments/{MODE}.yaml'),
])
aliased_solid = solid.alias('aliased_solid')
result = execute_solid(
aliased_solid,
mode_def=mode_defs[MODE],
environment_dict=environment_dict,
run_config=RunConfig(mode=MODE),
)
assert result.success
alex
03/17/2020, 9:54 PMexecute_solid
is just a thin wrapper around execute_pipeline
so I think your best bet may just be to use execute_pipeline
with a small
@pipeline
def test():
aliased_solid()
Basil V
03/17/2020, 9:54 PMBasil V
03/17/2020, 9:54 PMalex
03/17/2020, 9:56 PMexecute_pipeline
on your “real” pipeline definition and just use step_keys_to_execute
on RunConfig
to execute a single stepBasil V
03/17/2020, 9:59 PMBasil V
03/18/2020, 12:42 AMstep_keys_to_execute
param but getting:
dagster.core.errors.DagsterExecutionStepNotFoundError: Execution plan does not contain step: ...
Basil V
03/18/2020, 12:43 AMBasil V
03/18/2020, 12:43 AMsome_solid()
I specified the step key as 'some_solid' (or the alias name)Basil V
03/18/2020, 1:04 AM'solid_name.compute'
Basil V
03/18/2020, 1:04 AMalex
03/18/2020, 2:51 PM