Hi prefecters 👋 I stumbled on an interesting case: how can I test (unit test) a task which fails and has a retry (but without waiting for all retries to go… ? Currently I do this, however this works only when all retires have passed (which in my case takes a long time). Is there a way around this?

def test_smth():
    with Flow("test") as flow:
        outcome = my_funct()
    state = flow.run()
    assert state.result[outcome].is_failed()

Hi @Newskooler, In order to test at the level you’re looking at (flow-level outcomes with retries and whatnot) you may need to drop to the

FlowRunner

or

TaskRunner

level

Hi @Dylan what does that mean 🤔

For this specific question, you could try using environment variables when defining your flow to change

max_retires

in your Tasks to 0 for testing

Okay got it. I will inspect more with this info and if I see a case for an issue I will post one : ) Thanks!

You got it 👍