luciano/pods
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

set env var

Browse source
This commit is contained in:
Michiel Borkent 2020-05-09 17:30:20 +02:00
parent 2bbc8fa5ff
commit 7fea4149c9
3 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/babashka/pods/impl.clj
View file

@ -106,6 +106,8 @@
(let [pod-spec (if (string? pod-spec) [pod-spec] pod-spec) (let [pod-spec (if (string? pod-spec) [pod-spec] pod-spec)
pb (ProcessBuilder. ^java.util.List pod-spec) pb (ProcessBuilder. ^java.util.List pod-spec)
_ (.redirectError pb java.lang.ProcessBuilder$Redirect/INHERIT) _ (.redirectError pb java.lang.ProcessBuilder$Redirect/INHERIT)
_ (doto (.environment pb)
(.put "RUN_AS_BABASHKA_POD" "true"))
p (.start pb) p (.start pb)
stdin (.getOutputStream p) stdin (.getOutputStream p)
stdout (.getInputStream p) stdout (.getInputStream p)

3
test-pod/pod/test_pod.clj
View file

@ -112,4 +112,5 @@
:shutdown (System/exit 0)))))))) :shutdown (System/exit 0))))))))
(defn -main [& args] (defn -main [& args]
(run-pod (set args))) (when (= "true" (System/getenv "RUN_AS_BABASHKA_POD"))
(run-pod (set args))))

2
test/babashka/pods/test_common.clj
View file

@ -5,7 +5,7 @@
(require '[babashka.pods :as pods]) (require '[babashka.pods :as pods])
(require '[clojure.core.async :as async]) (require '[clojure.core.async :as async])
(pods/load-pod [\"clojure\" \"-A:test-pod\" \"--run-as-pod\"]) (pods/load-pod [\"clojure\" \"-A:test-pod\"])
(require '[pod.test-pod :as pod]) (require '[pod.test-pod :as pod])
(def stream-results (atom [])) (def stream-results (atom []))
(let [chan (pod.test-pod/range-stream 1 10)] (let [chan (pod.test-pod/range-stream 1 10)]