From e7fcc5cc4d68d969e589a65c6bfc514bef424f60 Mon Sep 17 00:00:00 2001 From: Jeremy Date: Wed, 15 Jul 2026 09:52:42 -0400 Subject: [PATCH] Don't change the current state when checkpointing --- lib/event_store/subscriptions/subscription_fsm.ex | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/lib/event_store/subscriptions/subscription_fsm.ex b/lib/event_store/subscriptions/subscription_fsm.ex index 5a2dd1bc..492d5289 100644 --- a/lib/event_store/subscriptions/subscription_fsm.ex +++ b/lib/event_store/subscriptions/subscription_fsm.ex @@ -109,7 +109,7 @@ defmodule EventStore.Subscriptions.SubscriptionFsm do end defevent checkpoint(), data: %SubscriptionState{} = data do - next_state(:subscribed, persist_checkpoint(data)) + next_state(:request_catch_up, persist_checkpoint(data)) end end @@ -123,7 +123,7 @@ defmodule EventStore.Subscriptions.SubscriptionFsm do end defevent checkpoint(), data: %SubscriptionState{} = data do - next_state(:subscribed, persist_checkpoint(data)) + next_state(:catching_up, persist_checkpoint(data)) end end @@ -199,7 +199,7 @@ defmodule EventStore.Subscriptions.SubscriptionFsm do end defevent checkpoint(), data: %SubscriptionState{} = data do - next_state(:subscribed, persist_checkpoint(data)) + next_state(:max_capacity, persist_checkpoint(data)) end end