adapt for binary outputs

fungi-coord/main.go

@@ -1,7 +1,6 @@
 package main
 
 import (
-	"encoding/json"
 	"fmt"
 	"log"
 	"os"
@@ -215,7 +214,7 @@ func (c *Coordinator) writeResult(job int, res *fungi.JobResult) error {
 	}
 	defer fi.Close()
 
-	if err := json.NewEncoder(fi).Encode(res); err != nil {
+	if _, err := fi.Write(res.Output); err != nil {
 		return xerrors.Errorf("failed to write result to file: %w", err)
 	}
 	return nil

fungi-worker/main.go

@@ -159,7 +159,7 @@ func (w *Worker) Execute(ja *fungi.JobAllocation) {
 		res := &fungi.JobResult{
 			JobID:   ja.ID,
 			Success: false,
-			Output:  string(out),
+			Output:  out,
 		}
 		w.Results <- res
 		return
@@ -168,7 +168,7 @@ func (w *Worker) Execute(ja *fungi.JobAllocation) {
 	w.Results <- &fungi.JobResult{
 		JobID:   ja.ID,
 		Success: true,
-		Output:  string(out),
+		Output:  out,
 	}
 }
 

types.go

@@ -19,7 +19,7 @@ type JobConfig struct {
 type JobResult struct {
 	JobID   int
 	Success bool
-	Output  string
+	Output  []byte
 }
 
 func LoadJobConfig(fn string) (*JobConfig, error) {