how to rerun the failed node in pipeline

[zhangjinrui2718]

1. how to retry the failed node in a completed-failed pipeline?
2. could i add some parameter like 'run date' or another into the pipeline then used in the pipeline? ( such parameter never changed once the a pipeline instance start , also in retry mode)

[saul-data]

For question 1, we need to add in that feature to re run a node or re run the rest of the pipeline if it fails at a certain point. It is on our to do list.

Question 2: There is an environment variable called DP_RUNID that is unique UUID used across the run. You can call that using:

import os
runid = os.getenv("DP_RUNID")

[zhangjinrui2718]

glad to see ur response , i m expecting the new feature , when will it be published

now pipeline has no stateful information , so that i cant re run the certain instance.
in my thought, the pipeline is just a logic DAG, running it will create a instance with stateful information , 'run date' or 'biz date' is an example and is very important/useful concept related to the instance

[marconimedeiros2]

After all, is there a rerun feature or not?