pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2026-05-27 02:14:05 +08:00
Code Issues Projects Releases Wiki Activity

docs: add WARNING line for silent duplicate skipping in BatchEnqueue

Browse Source
This commit is contained in:
Erik Nilsen
2026-04-10 09:56:35 -07:00
parent 06a06970d6
commit 68f03688e3
1 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
internal/rdb/rdb.go
View File

@@ -143,15 +143,14 @@ func (r *RDB) Enqueue(ctx context.Context, msg *base.TaskMessage) error {
// Each item is either enqueued immediately (ProcessAt is zero) or added to the
// scheduled sorted set.
//
// WARNING: tasks whose IDs already exist in Redis are silently skipped.
//
// The pipeline executes independent Lua scripts per task — there is no
// MULTI/EXEC wrapping the batch, so individual tasks may succeed or fail
// independently. A task whose ID already exists in Redis is skipped by the Lua
// script (returns 0) and does not count toward the returned enqueued total.
//
// The returned int is the number of tasks that were actually written to Redis
// (i.e. whose IDs did not already exist). The returned error is non-nil only
// when the pipeline call itself fails (network error, context cancellation,
// etc.), in which case no individual result should be trusted.
// independently. The returned int is the number of tasks actually written;
// skipped duplicates do not count. The returned error is non-nil only when the
// pipeline call itself fails (network error, context cancellation, etc.), in
// which case no individual result should be trusted.
//
// Message encoding errors cause an immediate return before any Redis I/O.
func (r *RDB) BatchEnqueue(ctx context.Context, items []base.BatchEnqueueItem) (int, error) {