diff --git a/events/code_coverage_events/workflow.py b/events/code_coverage_events/workflow.py
index 9b4ce142a..5834ec2ec 100644
--- a/events/code_coverage_events/workflow.py
+++ b/events/code_coverage_events/workflow.py
@@ -7,7 +7,6 @@
 from libmozevent.bus import MessageBus
 from libmozevent.monitoring import Monitoring
 from libmozevent.pulse import PulseListener
-from libmozevent.utils import retry
 from libmozevent.utils import run_tasks
 
 from code_coverage_events import QUEUE_MONITORING
@@ -81,7 +80,7 @@ def load_tasks(limit=200, continuationToken=None):
             query = {"limit": limit}
             if continuationToken is not None:
                 query["continuationToken"] = continuationToken
-            reply = retry(lambda: self.queue.listTaskGroup(group_id, query=query))
+            reply = self.queue.listTaskGroup(group_id, query=query)
             return maybe_trigger(reply["tasks"]), reply.get("continuationToken")
 
         async def retrieve_coverage_task():