Code cleanup

1 files changed, 3 insertions, 2 deletions

diff --git a/plugins/temporal/protocol/proto_codec.go b/plugins/temporal/protocol/proto_codec.go
index b41f02b6..607fe0fe 100644
--- a/plugins/temporal/protocol/proto_codec.go
+++ b/plugins/temporal/protocol/proto_codec.go
@@ -120,6 +120,7 @@ func (c *ProtoCodec) packMessage(msg Message) (*internal.Message, error) {
 }
 
 func (c *ProtoCodec) parseMessage(frame *internal.Message) (Message, error) {
+	const op = errors.Op("proto_codec_parse_message")
 	var err error
 
 	msg := Message{
@@ -131,12 +132,12 @@ func (c *ProtoCodec) parseMessage(frame *internal.Message) (Message, error) {
 	if frame.Command != "" {
 		msg.Command, err = initCommand(frame.Command)
 		if err != nil {
-			return Message{}, err
+			return Message{}, errors.E(op, err)
 		}
 
 		err = jsoniter.Unmarshal(frame.Options, &msg.Command)
 		if err != nil {
-			return Message{}, err
+			return Message{}, errors.E(op, err)
 		}
 	}