               :default 1000
               :doc "The number of segments to buffer after partitioning."}}}
 
-    :datomic/read-log
+    :onyx.plugin.datomic/read-log
     {:summary "Reads the transaction log via repeated chunked calls of d/tx-range. Continues to read transactions until `:datomic/log-end-tx` is reached, or forever if `:datomic/log-end-tx` is nil."
      :model {:datomic/uri
              {:type :string

              :default 1000
              :doc "The number of segments to buffer after partitioning."}}}

    :datomic/commit-tx
    {:summary "Writes new entity maps to datomic. Will automatically assign tempid's for the partition if a value for `:datomic/partition` is supplied and datomic transaction data is in map form. tx-data returned by `datomic.api/transact` is injected into the pipeline event map under `:datomic/written`."
     :model {:datomic/uri
             {:type :string

     :datomic/datoms-per-segment
     :datomic/read-buffer]

    :onyx.plugin.datomic/read-index-range
    [:datomic/uri
     :datomic/t
     :datomic/index-attribute
