               :optional? true
               :doc "When supplied, :db/id tempids are added using this partition."}}}
 
-    :datomic/commit-bulk-tx-async
+    :onyx.plugin.datomic/commit-bulk-tx-async
     {:summary "Writes transactions via the `:tx` segment key to a Datomic database. The value of `:tx` should be as if it were ready for `(d/transact uri tx)`. This lets you perform retractions and arbitrary db functions. tx-data returned by datomic.api/transact is injected into the pipeline event map under `:datomic/written`. Takes advantage of the Datomic transactor's ability to pipeline transactions by asynchronously transacting `:onyx/batch-size`transactions at once. Transaction futures are then derefed one by one after. Parallelism can thus be controlled by modifying the batch size appropriately. This is the recommended way to transact in bulk."
      :model {:datomic/uri
              {:type :string

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

    :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

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

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