         dm-sub (async/sub dm-pub username answer-chan)
         qas (reduce
              (fn [question-answers question]
+               (log/infof "Sending \"%s\" to %s" (:question/text question) username)
                (send-to-user! conn username (:question/text question))
                (conj question-answers
                      {:ts (java.util.Date.)

              :answer/text (:answer answer)
              :answer/ts (:ts answer)
              :question/_answers (:question-id answer)})]
    (prn tx)
    @(d/transact db-conn tx)))

(defjob QuestionnaireJob [job-data]
  (let [{:strs [domain db-conn]} (conversion/from-job-data job-data)
        db (d/db db-conn)
        token (:team/token (d/entity db [:team/domain domain]))
        users (d/q '[:find [?name ...]

                   (cron/schedule
                    (cron/cron-schedule cron-string))))]
    (scheduler/schedule scheduler job trigger)
    (log/info "Scheduler for" domain "is running with schedule" cron-string)))

(defn init-start-jobs [scheduler db-conn]
  (log/info "Starting the initial schedulers")
  (let [db (d/db db-conn)]
    (doseq [{:keys [team/domain team/schedule]}
            (d/q '[:find [(pull ?team [:team/domain :team/schedule]) ...]
                   :where
                   [?team :team/domain]]
                 db)]
      (if schedule
        (do (log/info "Scheduling" domain "with schedule" schedule)
            (schedule-questionnaire-job scheduler
                                        db-conn
                                        domain
                                        schedule))
        (do (log/info "Skipping scheduling for" domain))))))

(defn schedule-new [schduler db-before db-after]
  (let [new-domains (d/q '[:find [?new-domains ...]
