diff --git a/src/server_state.cpp b/src/server_state.cpp
index 32fff87..246f714 100644
--- a/src/server_state.cpp
+++ b/src/server_state.cpp
@@ -359,7 +359,8 @@ static int apply_write_set(wsrep::server_state& server_state,
                              ws_meta,
                              data);
     }
-    else if (ws_meta.flags() == 0 || wsrep::prepares_transaction(ws_meta.flags()))
+    else if (ws_meta.flags() == 0 || ws_meta.flags() == wsrep::provider::flag::pa_unsafe ||
+             wsrep::prepares_transaction(ws_meta.flags()))
     {
         wsrep::high_priority_service* sa(
             server_state.find_streaming_applier(