Skip to content

Commit dfdc413

Browse files
committed
partially restore WithStagePanicHandler comment
1 parent cf0cb9d commit dfdc413

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

pipe/pipeline.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -182,6 +182,10 @@ func WithEventHandler(handler func(e *Event)) Option {
182182
// WithStagePanicHandler sets a panic handler for the stages within a pipeline.
183183
// When a pipeline stage panics, the provided handler will be invoked, allowing
184184
// the client to handle the panic in whatever way they see fit.
185+
//
186+
// Note:
187+
// - The client is responsible for deciding whether to recover from the panic or panicking again.
188+
// - If a panic handler is not set, the panic will be propagated normally.
185189
func WithStagePanicHandler(ph StagePanicHandler) Option {
186190
return func(p *Pipeline) {
187191
p.panicHandler = ph

0 commit comments

Comments
 (0)