propagate out.Send error in external filter

This commit is contained in:
Daisuke Maki 2026-02-20 22:26:44 +09:00
parent e4e92ad5ac
commit deb12acf59

View file

@ -199,7 +199,7 @@ func (ecf *ExternalCmd) Apply(ctx context.Context, buf []line.Line, out pipeline
return nil
}
if err := out.Send(ctx, l); err != nil {
return nil
return err
}
}
}