Skip to content

Commit eb12059

Browse files
committed
Fix enqueuer panics when params are nil
1 parent 998398f commit eb12059

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

enqueuer.go

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -91,11 +91,13 @@ func (self *Enqueuer) Enqueue(ctx context.Context, task string, params any, opti
9191
return ErrEnqueuerGeneric.Raise().Cause(err)
9292
}
9393

94-
var data map[string]any
94+
data := make(map[string]any)
9595

96-
err = json.Unmarshal(payload, &data)
97-
if err != nil {
98-
return ErrEnqueuerGeneric.Raise().Cause(err)
96+
if params != nil {
97+
err = json.Unmarshal(payload, &data)
98+
if err != nil {
99+
return ErrEnqueuerGeneric.Raise().Cause(err)
100+
}
99101
}
100102

101103
data[_ENQUEUER_TASK_TRACE_ID_HEADER] = traceID

0 commit comments

Comments
 (0)