diff --git a/core/src/main/java/org/elasticsearch/cluster/SnapshotsInProgress.java b/core/src/main/java/org/elasticsearch/cluster/SnapshotsInProgress.java
index 54fec0734e5..2d3886aa52f 100644
--- a/core/src/main/java/org/elasticsearch/cluster/SnapshotsInProgress.java
+++ b/core/src/main/java/org/elasticsearch/cluster/SnapshotsInProgress.java
@@ -415,7 +415,7 @@ public class SnapshotsInProgress extends AbstractNamedDiffable<Custom> implement
             int shards = in.readVInt();
             for (int j = 0; j < shards; j++) {
                 ShardId shardId = ShardId.readShardId(in);
-                if (in.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {
+                if (in.getVersion().onOrAfter(Version.V_6_0_0_beta1)) {
                     builder.put(shardId, new ShardSnapshotStatus(in));
                 } else {
                     String nodeId = in.readOptionalString();
@@ -458,7 +458,7 @@ public class SnapshotsInProgress extends AbstractNamedDiffable<Custom> implement
             out.writeVInt(entry.shards().size());
             for (ObjectObjectCursor<ShardId, ShardSnapshotStatus> shardEntry : entry.shards()) {
                 shardEntry.key.writeTo(out);
-                if (out.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {
+                if (out.getVersion().onOrAfter(Version.V_6_0_0_beta1)) {
                     shardEntry.value.writeTo(out);
                 } else {
                     out.writeOptionalString(shardEntry.value.nodeId());