 
 (defnk create-session
   [contact-points datacenter keyspace :as args]
-  (->AliaSession
-   keyspace
-   (create-alia-session* args)))
+  (with-context deferred-context
+    (mlet [datastax-session (create-alia-session* args)]
+      (->AliaSession
+       keyspace
+       datastax-session))))
 
 (defn mutated-tables
   [spy-session]

    (swap! spy-log-atom conj statement)
    (execute-buffered* alia-session statement opts))
  (close [self]
    (when truncate-on-close
      (debug "truncating spy tables")
      (truncate-spy-tables self))
    (shutdown-session-and-cluster alia-session))

  KeyspaceProvider
  (keyspace [_] keyspace)

   [qbits.alia.policy.load-balancing :as lb]
   [qbits.alia.manifold :as aliam]
   [qbits.hayt :as h]
   [cats.core :refer [mlet return >>=]]
   [cats.context :refer [with-context]]
   [cats.labs.manifold :refer [deferred-context]]
   [er-cassandra.session :as s])
  (:import
   [er_cassandra.session
