Switch to latest onyx and onyx.core/write-batch.

onyx-platform · Nov 3, 2017 · c1674a1 · c1674a1
1 parent ac413cd
commit c1674a1
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/project.clj b/project.clj
@@ -14,7 +14,7 @@
   :dependencies [[org.clojure/clojure "1.8.0"]
                  [org.clojure/data.json "0.2.6"]
                  ^{:voom {:repo "git@github.com:onyx-platform/onyx.git" :branch "master"}}
-                 [org.onyxplatform/onyx "0.11.1"]
+                 [org.onyxplatform/onyx "0.11.2-20171103.054521-9"]
                  [com.taoensso/carmine "2.15.1" :exclusions [com.taoensso/timbre com.taoensso/encore]]]
   :profiles {:dev {:dependencies [[aero "0.2.0"]]
                    :plugins [[lein-set-version "0.4.1"]

diff --git a/src/onyx/plugin/redis.clj b/src/onyx/plugin/redis.clj
@@ -98,10 +98,10 @@
   (prepare-batch [this event replica _]
     true)
 
-  (write-batch [this {:keys [onyx.core/results]} replica _]
+  (write-batch [this {:keys [onyx.core/write-batch]} replica _]
     (wcar conn (doall
                 (map (partial perform-operation config)
-                     (mapcat :leaves (:tree results)))))
+                     write-batch)))
     true))
 
 (defn writer [event]