diff --git a/src/cluster_client.cpp b/src/cluster_client.cpp
index 414e7154..7c1fd8e9 100644
--- a/src/cluster_client.cpp
+++ b/src/cluster_client.cpp
@@ -757,7 +757,10 @@ resume_3:
         {
             for (int i = 0; i < op->parts.size(); i++)
             {
-                op->parts[i].flags = PART_RETRY;
+                if (!(op->parts[i].flags & PART_DONE))
+                {
+                    op->parts[i].flags = PART_RETRY;
+                }
             }
             goto resume_2;
         }