Use workflowID instead of workerID in getWorkflowData

tinkerbell · Apr 6, 2022 · 838a8a6 · 838a8a6
1 parent d3512cb
commit 838a8a6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cmd/tink-worker/worker/worker.go b/cmd/tink-worker/worker/worker.go
@@ -471,7 +471,7 @@ func (w *Worker) getWorkflowData(ctx context.Context, workflowID string) {
 	}
 
 	if len(res.GetData()) != 0 {
-		wfDir := filepath.Join(w.dataDir, w.workerID)
+		wfDir := filepath.Join(w.dataDir, workflowID)
 		f := openDataFile(wfDir, l)
 		defer func() {
 			if err := f.Close(); err != nil {