pass payload as StdIn to task runner (#648)

iron-io · Sep 22, 2017 · 330088d · 330088d
1 parent d434952
commit 330088d
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/api/runner/async_runner.go b/api/runner/async_runner.go
@@ -10,6 +10,7 @@ import (
 	"net/http"
 	"net/url"
 	"sync"
+	"strings"
 	"time"
 
 	"github.com/Sirupsen/logrus"
@@ -56,6 +57,7 @@ func getCfg(t *models.Task) *task.Config {
 		IdleTimeout: time.Duration(*t.IdleTimeout) * time.Second,
 		ID:      t.ID,
 		AppName: t.AppName,
+		Stdin:   strings.NewReader(t.Payload),
 		Env:     t.EnvVars,
 	}
 	return cfg