From 153b839de54c1dd1fe5b80c9717b1a2c5e5fee20 Mon Sep 17 00:00:00 2001 From: Michael Avila Date: Mon, 1 Jul 2019 15:24:06 -0700 Subject: [PATCH] Avoid collisions by appending cid --- provider/queue/queue.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/provider/queue/queue.go b/provider/queue/queue.go index dceb67447a71..293552233715 100644 --- a/provider/queue/queue.go +++ b/provider/queue/queue.go @@ -110,7 +110,8 @@ func (q *Queue) work() { select { case toQueue := <-q.enqueue: - nextKey := datastore.NewKey(fmt.Sprintf("%d", time.Now().UnixNano())) + keyPath := fmt.Sprintf("%d/%s", time.Now().UnixNano(), c.String()) + nextKey := datastore.NewKey(keyPath) if err := q.ds.Put(nextKey, toQueue.Bytes()); err != nil { log.Errorf("Failed to enqueue cid: %s", err)