Does anyone have an example of providing an op retry policy on an op invocation? the docs mention this pattern but I haven't been able to find any examples of it, and when I try to just feed in the retry policy to the op invocation I get an error expecting retry_policy to be an input from an upstream op (which is kinda what I thought would happen) - example:

@graph
def trigger_graph():
    job_args = setup_job_args()
    run_now(job_args, retry_policy=RetryPolicy())

obnoxious but relevant example https://github.com/dagster-io/dagster/blame/master/python_modules/dagster/dagster_tests/execution_tests/test_retries.py#L475-L482

lol perfect, thanks a bunch!

Yes, we should point to

with_retry_policy

in the docs

Created issue at: https://github.com/dagster-io/dagster/issues/7711