fixes #1019 (#1020)

this commit fixes #1019
distribworks · Sep 30, 2021 · 94abc75 · 94abc75
1 parent 2026a40
commit 94abc75
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/builtin/bins/dkron-executor-nats/nats.go b/builtin/bins/dkron-executor-nats/nats.go
@@ -73,6 +73,11 @@ func (s *Nats) ExecuteImpl(args *dktypes.ExecuteRequest) ([]byte, error) {
 	if debug {
 		log.Printf("request  %#v\n\n", nc)
 	}
+
+	if nc.IsConnected() {
+		defer nc.Flush()
+		defer nc.Close()
+	}
 
 	return output.Bytes(), nil
 }