Skip to content

Commit

Permalink
Update comment
Browse files Browse the repository at this point in the history
  • Loading branch information
jaredoconnell committed Jul 8, 2024
1 parent 067cc38 commit a676ab4
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions atp/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -572,9 +572,9 @@ func (c *client) getResultV2(stepData schema.Input) ExecutionResult {
panic(fmt.Errorf("did not receive result from results entry in ATP client for step with run ID '%s'",
stepData.RunID))
}
// Now that we've received the result for this step, remove it from the list
// of running steps so that we won't see it as running anymore.
// It cannot be removed on the sender's side, since that would cause a race.
// Now that we've received the result for this step, remove it from the list of running steps.
// We do this here because the sender cannot tell when the message has been received, and so
// it cannot tell when it is safe to remove the entry from the map.
delete(c.runningStepResultEntries, stepData.RunID)
return *resultEntry.result
}
Expand Down

0 comments on commit a676ab4

Please sign in to comment.