Skip to content

Commit

Permalink
[tink-worker] Use workflowID instead of workerID in getWorkflowData (#…
Browse files Browse the repository at this point in the history
…604)

## Description

All other workflow data operations in tink-worker are using workflowID, this aligns getWorkflowData to use the same convention.

## Why is this needed

This was causing tink-worker to fail to successfully run through workflows complaining that it couldn't open the right data file for tracking the workflow.

## How Has This Been Tested?

Tested this locally using the sandbox configured to use the latest published components, and a version of tink-worker that I had build and pushed to a registry that I control.

## How are existing users impacted? What migration steps/scripts do we need?

No existing users should be impacted, since the issue does not exist in the previous sandbox release.
  • Loading branch information
mergify[bot] authored Apr 6, 2022
2 parents d3512cb + 838a8a6 commit 08a2e12
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion cmd/tink-worker/worker/worker.go
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down

0 comments on commit 08a2e12

Please sign in to comment.