Fixed input

api/runner/async_runner.go

@@ -9,6 +9,7 @@ import (
 	"net"
 	"net/http"
 	"net/url"
+	"strings"
 	"sync"
 	"time"
 
@@ -48,6 +49,7 @@ func getCfg(t *models.Task) *task.Config {
 		AppName: t.AppName,
 		Env:     t.EnvVars,
 		Ready:   make(chan struct{}),
+		Stdin:   strings.NewReader(t.Payload),
 	}
 	if t.Timeout == nil || *t.Timeout <= 0 {
 		cfg.Timeout = DefaultTimeout

api/runner/worker.go

@@ -5,7 +5,6 @@ import (
 	"errors"
 	"fmt"
 	"io"
-	"strings"
 	"sync"
 	"time"
 
@@ -64,10 +63,6 @@ func (rnr *Runner) RunTrackedTask(newTask *models.Task, ctx context.Context, cfg
 	startedAt := strfmt.DateTime(time.Now())
 	newTask.StartedAt = startedAt
 
-	// set payload as Stdin
-	// fmt.Printf("ABOUT TO PASS IN PAYLOAD: %v", newTask.Payload)
-	cfg.Stdin = strings.NewReader(newTask.Payload)
-
 	result, err := rnr.RunTask(ctx, cfg)
 
 	completedAt := strfmt.DateTime(time.Now())