diff --git a/src/cluster.cpp b/src/cluster.cpp
index 1ebaed262..15c030162 100644
--- a/src/cluster.cpp
+++ b/src/cluster.cpp
@@ -5272,6 +5272,7 @@ try_again:
         zfree(ov); zfree(kv);
         return; /* error sent to the client by migrateGetSocket() */
     }
+    connMarshalThread(cs->conn);
 
     rioInitWithBuffer(&cmd,sdsempty());
 
diff --git a/src/tls.cpp b/src/tls.cpp
index 0f59fb3bd..4284a27bf 100644
--- a/src/tls.cpp
+++ b/src/tls.cpp
@@ -349,6 +349,7 @@ connection *connCreateTLS(void) {
 
 void connTLSMarshalThread(connection *c) {
     tls_connection *conn = (tls_connection*)c;
+    serverAssert(conn->pending_list_node == nullptr);
     conn->el = serverTL->el;
 }