diff --git a/deps.edn b/deps.edn index c0f5b29..c1e184d 100644 --- a/deps.edn +++ b/deps.edn @@ -1,6 +1,6 @@ {:paths ["src"] :deps {com.taoensso/timbre {:mvn/version "5.1.2"} - io.replikativ/konserve {:mvn/version "0.7.285"} + io.replikativ/konserve {:mvn/version "0.7.319"} io.replikativ/superv.async {:mvn/version "0.3.43"} org.clojure/clojure {:mvn/version "1.10.3"} diff --git a/src/konserve_s3/core.clj b/src/konserve_s3/core.clj index baf1218..1be0e23 100644 --- a/src/konserve_s3/core.clj +++ b/src/konserve_s3/core.clj @@ -4,7 +4,8 @@ [konserve.impl.storage-layout :refer [PBackingStore PBackingBlob PBackingLock -delete-store header-size]] [konserve.utils :refer [async+sync *default-sync-translation*]] [superv.async :refer [go-try-]] - [taoensso.timbre :refer [info trace]]) + [taoensso.timbre :refer [info trace]] + [clojure.core.async :refer [chan]]) (:import [java.io ByteArrayInputStream ByteArrayOutputStream] [java.util Arrays] ;; AWS API @@ -270,7 +271,8 @@ backing (S3Bucket. (s3-client s3-spec) (:bucket s3-spec) (:store-id s3-spec)) config (merge {:opts complete-opts :config {:sync-blob? true - :in-place? false + :in-place? true + :no-backup? true :lock-blob? true} :default-serializer :FressianSerializer :buffer-size (* 1024 1024)}