Skip to content

Commit c8ef857

Browse files
committed
typo
Signed-off-by: Fabian Martinez <[email protected]>
1 parent 3936e45 commit c8ef857

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

backend/executor.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -281,7 +281,7 @@ func (g *grpcExecutor) GetWorkItems(req *protos.GetWorkItemsRequest, stream prot
281281

282282
// There are some cases where the app may need to be notified when a client connects to fetch work items, like
283283
// for auto-starting the worker. The app also has an opportunity to set itself as unavailable by returning an error.
284-
if err := g.executeOoWorkItemConnection(stream.Context()); err != nil {
284+
if err := g.executeOnWorkItemConnection(stream.Context()); err != nil {
285285
message := "unable to establish work item stream at this time: " + err.Error()
286286
g.logger.Warn(message)
287287

@@ -397,7 +397,7 @@ func (g *grpcExecutor) sendWorkItem(stream protos.TaskHubSidecarService_GetWorkI
397397
}
398398
}
399399

400-
func (g *grpcExecutor) executeOoWorkItemConnection(ctx context.Context) error {
400+
func (g *grpcExecutor) executeOnWorkItemConnection(ctx context.Context) error {
401401
if callback := g.onWorkItemConnection; callback != nil {
402402
if err := callback(ctx); err != nil {
403403
return err

0 commit comments

Comments
 (0)