Skip to content

Commit

Permalink
GetExpirationTime comment
Browse files Browse the repository at this point in the history
  • Loading branch information
github-actions committed Mar 8, 2022
1 parent 3e4a89d commit 177691b
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions sdks/go/pkg/beam/core/runtime/exec/plan.go
Original file line number Diff line number Diff line change
Expand Up @@ -175,6 +175,8 @@ func (p *Plan) Finalize() error {
return nil
}

// GetExpirationTime returns the last expiration time of any of the callbacks registered by the bundleFinalizer.
// Once we have passed this time, it is safe to move this plan to inactive without missing any valid callbacks.
func (p *Plan) GetExpirationTime() time.Time {
return p.bf.lastValidCallback
}
Expand Down

0 comments on commit 177691b

Please sign in to comment.