    [deferst :refer [defsystem]]
    [deferst.system :as sys]
    [slf4j-timbre.configure :as logconf]
+   [manifold.stream :as stream]
    [er-cassandra.record :as r]
    [er-cassandra.session :as s]
    [er-cassandra.model :as m]

  ([entity record] (upsert-instance entity record nil))
  ([entity record opts]
   @(m/upsert *model-session* entity record (ts/past-timestamp-opt opts))))

(def alia-test-model-session-config
  {:timbre {:level :warn}
   :config {:alia-session
            {:keyspace "er_cassandra_test"
             :truncate-on-close false}}})

(def alia-test-model-session-system-def
  [[:logging logconf/configure-timbre [:timbre]]
