         metadata (doto (ObjectMetadata.)
                    (.setContentLength size)
                    (.setContentMD5 md5))
-        _ (some->> content-type
-                   (.setContentType metadata))
-        _ (some->> encryption-setting
-                   (.setSSEAlgorithm metadata))
+        _ (some->> content-type (.setContentType metadata))
+        _ (some->> encryption-setting (.setSSEAlgorithm metadata))
         put-request (PutObjectRequest. bucket
                                        key
                                        (ByteArrayInputStream. serialized)

         (name checkpoint-type))))

(defmethod checkpoint/write-checkpoint onyx.storage.s3.CheckpointManager
  [{:keys [transfer-manager transfers bucket] :as storage} tenancy-id job-id replica-version epoch
   task-id slot-id checkpoint-type ^bytes checkpoint-bytes]
  (let [k (checkpoint-task-key tenancy-id job-id replica-version epoch task-id
                               slot-id checkpoint-type)

           [java.util.concurrent TimeUnit]
           [java.util.concurrent.atomic AtomicLong]))



(defn new-client ^AmazonS3Client [peer-config]
   (case (arg-or-default :onyx.peer/storage.s3.auth-type peer-config)
     :provider-chain (let [credentials (DefaultAWSCredentialsProviderChain.)]
