diff --git a/src/clj/auto_ap/graphql/requests.clj b/src/clj/auto_ap/graphql/requests.clj index aa33e9c7..2c6e8bc0 100644 --- a/src/clj/auto_ap/graphql/requests.clj +++ b/src/clj/auto_ap/graphql/requests.clj @@ -3,7 +3,8 @@ [amazonica.aws.ecs :as ecs] [auto-ap.graphql.utils :refer [assert-admin assert-failure]] [clojure.string :as str] - [config.core :refer [env]]) + [config.core :refer [env]] + [clojure.tools.logging :as log]) (:import (com.amazonaws.services.ecs.model AssignPublicIp))) @@ -21,6 +22,7 @@ ) (defn run-task [task] + (log/info "running job" task) (ecs/run-task :capacity-provider-strategy [{:base 1 :weight 1 :capacity-provider "FARGATE_SPOT"}] :count 1 :cluster "default" @@ -32,7 +34,7 @@ (defn request-import [context value _] (assert-admin (:id context)) - (let [job (str (str/replace (name (:which value)) #"-" "_") "_" (:dd-env env))] + (let [job (str (str/replace (str/replace (name (:which value)) #":" "") #"-" "_") "_" (:dd-env env))] (if (not (get (currently-running-jobs) job)) (run-task job) (assert-failure "This job is already running"))))