https://dagster.io/ logo
Title
s

Sheya Bernstein

12/14/2022, 2:45 PM
Hey folks, is there an option of settings up dagster retries for a pipeline to automatically be re-executed on error? Similar to this article for jobs
j

jamie

12/14/2022, 8:26 PM
Hey @Sheya Bernstein are you referring to pipeline as in the pre-op/graph/job concept of pipeline? or something else?
s

Sheya Bernstein

12/15/2022, 10:52 AM
Hey Jamie, I'm referring to a pipeline comprised of a graph of ops
j

jamie

12/15/2022, 2:58 PM
ok - and you’re directly running the graph? along the lines of
@op 
def my_op():
   return 1

@graph
def my_graph():
    my_op()

my_graph.execute_in_process()
or adding the graph to your repository like
@repository 
def my_repo():
    return [my_graph]
I believe that automatically run retries might work directly on the graph. if that’s not the behavior you see, let me know! (any error messaging would be helpful too)
s

Sheya Bernstein

12/15/2022, 4:01 PM
I'm adding the graph to the repository
j

jamie

12/15/2022, 4:02 PM
ok. as far as i know it might still work. have you tried it and not seeing the retries?