Merge pull request #2 from davidad/binary-outputs

adapt for binary outputs
filecoin-project · May 4, 2020 · 95b77c5 · 95b77c5
2 parents 54594cb + 79ddbe9
commit 95b77c5
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 5 deletions.
diff --git a/fungi-coord/main.go b/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

diff --git a/fungi-worker/main.go b/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,
 	}
 }
 

diff --git a/types.go b/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) {