How can I know if the current execution is a retry?

[sryza]

For an Op retry policy, how can we know inside the op context if the current execution is a retry?

[sryza]

You can use context.retry_number.

@op(retry_policy=RetryPolicy(max_retries=2))
def my_op(context):
    is_retry = context.retry_number > 0
    ...

[RWiggers]

This isn’t working for me. Every time an op fails, Dagster seems to create a new context and resets retrying_number back to zero