Showing 23 of 36 total issues
Method Streamdal.runStep
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func (s *Streamdal) runStep(ctx context.Context, aud *protos.Audience, step *protos.PipelineStep, data []byte, isr *protos.InterStepResult) (*protos.WASMResponse, error) {
Method Streamdal.createFunction
has 5 return statements (exceeds 4 allowed). Open
Open
func (s *Streamdal) createFunction(step *protos.PipelineStep) (*function, error) {
inst, err := s.createWASMInstance(step.GetXWasmBytes())
if err != nil {
return nil, errors.Wrap(err, "unable to create WASM instance")
}
Method Streamdal.runStep
has 5 return statements (exceeds 4 allowed). Open
Open
func (s *Streamdal) runStep(ctx context.Context, aud *protos.Audience, step *protos.PipelineStep, data []byte, isr *protos.InterStepResult) (*protos.WASMResponse, error) {
s.config.Logger.Debugf("Running step '%s'", step.Name)
// Get WASM module
f, err := s.getFunction(ctx, step)