pkg/flow/instance_messages.go
Method engine.enqueueInstanceMessage
has 7 return statements (exceeds 4 allowed). Open
Open
func (engine *engine) enqueueInstanceMessage(ctx context.Context, id uuid.UUID, kind string, data interface{}) error {
// TODO: should this add state and step data? At some point these fields died so I have removed them.
payload, err := json.Marshal(map[string]interface{}{
"type": kind,
"data": data,
Method engine.handleInstanceMessage
has 5 return statements (exceeds 4 allowed). Open
Open
func (engine *engine) handleInstanceMessage(ctx context.Context, im *instanceMemory, msg *instancestore.InstanceMessageData) *states.Transition {
nsCtx := im.Namespace().WithTags(ctx)
instanceCtx := im.WithTags(nsCtx)
nsCtx = tracing.WithTrack(instanceCtx, tracing.BuildNamespaceTrack(im.Namespace().Name))
ctx = tracing.WithTrack(instanceCtx, tracing.BuildInstanceTrack(im.instance))