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

Makes new job for Brian

Browse Source
This commit is contained in:
Bryce Covert
2022-09-30 23:19:15 -07:00
parent 556d6311ff
commit 55e3df7e94
5 changed files with 49 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
src/clj/auto_ap/graphql/jobs.clj
View File

@@ -8,7 +8,8 @@
[clojure.string :as str]
[config.core :refer [env]]
[clojure.tools.logging :as log]
[com.walmartlabs.lacinia.util :refer [attach-resolvers]])
[com.walmartlabs.lacinia.util :refer [attach-resolvers]]
[clojure.edn :as edn])
(:import
(com.amazonaws.services.ecs.model AssignPublicIp)))
@@ -80,21 +81,23 @@
(map :name)
set))
(defn run-task [task]
(defn run-task [task args]
(log/info "running job" task)
(ecs/run-task :capacity-provider-strategy [{:base 1 :weight 1 :capacity-provider "FARGATE_SPOT"}]
:count 1
:cluster "default"
:enable-ecs-managed-tags true
:task-definition task
:network-configuration {:aws-vpc-configuration {:subnets ["subnet-5e675761" "subnet-8519fde2" "subnet-89bab8d4"]
:security-groups ["sg-004e5855310c453a3" "sg-02d167406b1082698"]
:assign-public-ip AssignPublicIp/ENABLED}}))
(ecs/run-task (cond-> {:capacity-provider-strategy [{:base 1 :weight 1 :capacity-provider "FARGATE_SPOT"}]
:count 1
:cluster "default"
:enable-ecs-managed-tags true
:task-definition task
:network-configuration {:aws-vpc-configuration {:subnets ["subnet-5e675761" "subnet-8519fde2" "subnet-89bab8d4"]
:security-groups ["sg-004e5855310c453a3" "sg-02d167406b1082698"]
:assign-public-ip AssignPublicIp/ENABLED}}}
args (assoc-in [:overrides :container-overrides ] [{:name "integreat-app" :environment [{:name "args" :value (pr-str task)}]}]))))
(defn request-job [context value _]
(assert-admin (:id context))
(if (not (get (currently-running-jobs) (:which value)))
(let [new-job (run-task (str (str/replace (:which value) #"-" "_") "_" (:dd-env env)))]
(let [new-job (run-task (str (str/replace (:which value) #"-" "_") "_" (:dd-env env))
(some-> (:args value) edn/read-string))]
{:message (str "task " (str new-job) " started.")})
(assert-failure "This job is already running")))