feat(AveragePosition): no return value
This commit is contained in:
@ -281,17 +281,6 @@ func (o *Operations) AveragePosition(ctx context.Context) (*protocol.TaskMessage
|
|||||||
if err = o.client.Emit("task", &model.Action{Name: "average_base_coordinates"}); err != nil {
|
if err = o.client.Emit("task", &model.Action{Name: "average_base_coordinates"}); err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
ch, err := o.On(ctx, "task_status")
|
|
||||||
for message := range ch {
|
|
||||||
var taskMsg protocol.TaskMessage[protocol.AveragePositionPayload]
|
|
||||||
if err := mapstructure.Decode(message, &taskMsg); err != nil {
|
|
||||||
return nil, errors.WithStack(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
if taskMsg.State == "completed" {
|
|
||||||
return &taskMsg, nil
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user