Compare commits
2 Commits
08f12ab5cb
...
master
Author | SHA1 | Date | |
---|---|---|---|
4050090814 | |||
05f5b3f771 |
@ -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