notid/integreat
1
0
Fork 0
Code Issues Pull Requests 2 Actions Packages Projects Releases Wiki Activity

another try for different approach to requests.

Browse Source
This commit is contained in:
Bryce Covert
2022-09-27 10:49:27 -07:00
parent 5b17340eda
commit 90743ab3a3
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/clj/auto_ap/graphql/requests.clj
View File

@@ -3,7 +3,8 @@
[amazonica.aws.ecs :as ecs] [amazonica.aws.ecs :as ecs]
[auto-ap.graphql.utils :refer [assert-admin assert-failure]] [auto-ap.graphql.utils :refer [assert-admin assert-failure]]
[clojure.string :as str] [clojure.string :as str]
[config.core :refer [env]]) [config.core :refer [env]]
[clojure.tools.logging :as log])
(:import (:import
(com.amazonaws.services.ecs.model AssignPublicIp))) (com.amazonaws.services.ecs.model AssignPublicIp)))
@@ -21,6 +22,7 @@
) )
(defn run-task [task] (defn run-task [task]
(log/info "running job" task)
(ecs/run-task :capacity-provider-strategy [{:base 1 :weight 1 :capacity-provider "FARGATE_SPOT"}] (ecs/run-task :capacity-provider-strategy [{:base 1 :weight 1 :capacity-provider "FARGATE_SPOT"}]
:count 1 :count 1
:cluster "default" :cluster "default"
@@ -32,7 +34,7 @@
(defn request-import [context value _] (defn request-import [context value _]
(assert-admin (:id context)) (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)) (if (not (get (currently-running-jobs) job))
(run-task job) (run-task job)
(assert-failure "This job is already running")))) (assert-failure "This job is already running"))))