Effect CommunityEC
Effect Community•14mo ago
'Ken' a.k.a. 'Frosty'

Resetting Retry Attempts in Effect Typescript

"Resetting" retry attempts


Imagine you have a long-running process (possibly via a Stream) that you want to recover with retries. Then, if successfully ran, 'reset' those retry conditions so that on the next failure, the retries start from the beginning again.


Picture this for recovering a websocket connection clientside:
        const connect_socket_with_retry = connect_socket_Effect
            .pipe(
                Effect.retry({
                    schedule: Schedule.intersect(
                        Schedule.recurUpTo('30 seconds'),
                        Schedule.exponential('20 millis').pipe(Schedule.jittered)
                    )
                        .pipe(
                            Schedule.andThen(
                                Schedule.intersect(
                                    Schedule.recurUpTo('10 minutes'),
                                    Schedule.spaced('10 seconds').pipe(Schedule.jittered)
                                )
                            )
                        )
                        .pipe(
                            Schedule.andThen(
                                Schedule.intersect(
                                    Schedule.recurUpTo('6 hours'),
                                    Schedule.spaced('30 seconds').pipe(Schedule.jittered)
                                )
                            )
                        ),
                })
            )
            .pipe(Effect.tapError(() => Effect.log(`Connection retries exhausted. No longer will retry.`)));


But at once a retry is successful, you'd want the next failure to start from the first schedule again. As this code is, the next failure will pick up where it left off, which makes sense! But is there a simple way to do this or are we getting into custom retry management territory?
Was this page helpful?