   (execute-buffered [_ statement opts]
     (execute-buffered* alia-session statement opts))
   (close [_]
-    (.close alia-session)))
+    (shutdown-session-and-cluster alia-session)))
 
 (defnk create-session
   [contact-points datacenter keyspace :as args]

  (close [self]
    (when truncate-on-close
      (truncate-spy-tables self))
    (.close alia-session))

  KeyspaceProvider
  (keyspace [_] keyspace)

       (h/->raw statement)))
   opts))

(defn shutdown-session-and-cluster
  [session]
  (info "closing underlying alia session and cluster")
  (let [cluster (.getCluster session)]
    (alia/shutdown session)
    (alia/shutdown cluster)))

(defnk ^:private create-alia-session*
  [contact-points
   datacenter
