diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go
index 1143e42d34..c452f6d7a1 100644
--- a/flow/activities/flowable.go
+++ b/flow/activities/flowable.go
@@ -693,7 +693,7 @@ func GetPostgresPeerConfigs(ctx context.Context) ([]*protos.PostgresConfig, erro
 }
 
 func (a *FlowableActivity) SendWALHeartbeat(ctx context.Context) error {
-	sendTimeout := 10 * time.Second
+	sendTimeout := 10 * time.Minute
 	ticker := time.NewTicker(sendTimeout)
 	defer ticker.Stop()