diff --git a/dyn/core.py b/dyn/core.py
index 0e12036..69795f8 100644
--- a/dyn/core.py
+++ b/dyn/core.py
@@ -249,7 +249,7 @@ def _retry(self, msgs, final=False):
         """Retry logic around throttled or blocked tasks"""
 
         throttle_err = 'RATE_LIMIT_EXCEEDED'
-        throttled = any(throttle_err == err['ERR_CD'] for err in msgs)
+        throttled = any(throttle_err == err.get('ERR_CD') for err in msgs)
 
         if throttled:
             # We're rate limited, so wait 5 seconds and try again