From 838a8a607e20467314e09f988da8220c745962fc Mon Sep 17 00:00:00 2001 From: Jason DeTiberus Date: Wed, 6 Apr 2022 14:51:56 -0400 Subject: [PATCH] Use workflowID instead of workerID in getWorkflowData --- cmd/tink-worker/worker/worker.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cmd/tink-worker/worker/worker.go b/cmd/tink-worker/worker/worker.go index 32e79a9d8..01af0dbb9 100644 --- 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 {