               :optional? true
               :doc "When supplied, :db/id tempids are added using this partition."}}}
 
-    :datomic/commit-bulk-tx
+    :onyx.plugin.datomic/commit-bulk-tx
     {:summary "Exactly the same as commit-bulk-tx (asynchronous), but transacts each tx completely (blocking on the returned future) before proceeding to the next. You should generally prefer the async version."
      :model {:datomic/uri
              {:type :string

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

    :datomic/read-index-range
    {:summary "Reads datoms from an indexed attribute via `datomic.api/index-range`."
     :model {:datomic/uri
             {:type :string

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

    :onyx.plugin.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
