Peter Skipper
11/10/2022, 11:31 PMreexecute_pipeline
from dagster 1.0.15, which makes me think there is now another way?yuhan
11/10/2022, 11:43 PMfrom dagster import ReexecutionOptions, execute_job
instance = DagsterInstance.get()
options = ReexecutionOptions.from_failure(run_id=failed_run_id, instance)
execute_job(reconstructable(job), instance, reexecution_options=options)