diff --git a/src/eredis_cluster.erl b/src/eredis_cluster.erl
index 1da3a9f..9428afe 100644
--- a/src/eredis_cluster.erl
+++ b/src/eredis_cluster.erl
@@ -194,6 +194,7 @@ handle_transaction_result(Result, Version) ->
        % If we detect a node went down, we should probably refresh the slot
         % mapping.
         {error, no_connection} ->
+            logger:error("eredis_cluster:handle_transaction_result <--> {error, no_connection}",[]),
             eredis_cluster_monitor:refresh_mapping(Version),
             retry;
 
@@ -202,11 +203,17 @@ handle_transaction_result(Result, Version) ->
         % the next request. We don't need to refresh the slot mapping in this
         % case
         {error, tcp_closed} ->
+            logger:error("eredis_cluster:handle_transaction_result <--> {error, no_connection}",[]),
+            retry;
+
+        {error, retry} ->
+            logger:error("eredis_cluster:handle_transaction_result <--> {error, retry}",[]),
             retry;
 
         % Redis explicitly say our slot mapping is incorrect, we need to refresh
         % it
         {error, <<"MOVED ", _/binary>>} ->
+            logger:error("eredis_cluster:handle_transaction_result <--> {error, MOVED} Result = ~",[Result]),
             eredis_cluster_monitor:refresh_mapping(Version),
             retry;
 
diff --git a/src/eredis_cluster_pool_worker.erl b/src/eredis_cluster_pool_worker.erl
index 6fd0ef0..e2507a9 100644
--- a/src/eredis_cluster_pool_worker.erl
+++ b/src/eredis_cluster_pool_worker.erl
@@ -38,6 +38,8 @@ init(Args) ->
 
     {ok, #state{conn=Conn}}.
 
+query(full, _Commands) ->
+    {error, retry};
 query(Worker, Commands) ->
     gen_server:call(Worker, {'query', Commands}).