   (let [ch (chan 1)]
     (go
       (let [[v c] (alts! [ch (timeout timeout-collect)])]
-        (when (nil? v)
+        (if (nil? v)
           (log/log-error
             "Timeout collecting vms for user "
             (.getName user)
             " on cloud "
-            (.getConnectorInstanceName connector)))))
+            (.getConnectorInstanceName connector))
+          (log/log-info (str "executed collect request for " (.getName user) " and " (.getConnectorInstanceName connector))))))
     (go (>! ch (Collector/collect user connector)))))
 
 (defn update-metric!

  (let [ch (chan 1)]
    (go
      (let [[v c] (alts! [ch (timeout timeout-collect)])]
        (when (nil? v)
          (log/log-error
            "Timeout updating metrics for user "
            (.getName user)))))
    (go (>! ch (updator/update user)))))

(def not-nil? (complement nil?))

(defn insert-collection-requests
  [users]
  (doseq [user users
          connector (connectors)]
    (go 
      (>! collector-chan [user connector]))))

