Remove payload debug
This commit is contained in:
@@ -477,7 +477,7 @@ func WithWorkflowId(id string) EnqueueOption {
|
|||||||
|
|
||||||
// Enqueue adds a new job to the queue
|
// Enqueue adds a new job to the queue
|
||||||
func (q *GeneralQueue) Enqueue(ctx context.Context, payload any, maxRetries int, userId int, options ...EnqueueOption) (*ent.GeneralQueue, error) {
|
func (q *GeneralQueue) Enqueue(ctx context.Context, payload any, maxRetries int, userId int, options ...EnqueueOption) (*ent.GeneralQueue, error) {
|
||||||
Debug("Enqueueing job to queue:", q.Name, "payload", payload)
|
Debug("Enqueueing job to queue:", q.Name)
|
||||||
params := EnqueueParams{}
|
params := EnqueueParams{}
|
||||||
for _, option := range options {
|
for _, option := range options {
|
||||||
option(¶ms)
|
option(¶ms)
|
||||||
|
|||||||
Reference in New Issue
Block a user