diff --git a/selfdrive/athena/athenad.py b/selfdrive/athena/athenad.py
index bd946a097..71a18aff7 100755
--- a/selfdrive/athena/athenad.py
+++ b/selfdrive/athena/athenad.py
@@ -206,7 +206,7 @@ def upload_handler(end_event: threading.Event) -> None:
         cloudlog.event("athena.upload_handler.upload_start", fn=fn, sz=sz, network_type=network_type, metered=metered, retry_count=cur_upload_items[tid].retry_count)
         response = _do_upload(cur_upload_items[tid], cb)
 
-        if response.status_code not in (200, 201, 403, 412):
+        if response.status_code not in (200, 201, 401, 403, 412):
           cloudlog.event("athena.upload_handler.retry", status_code=response.status_code, fn=fn, sz=sz, network_type=network_type, metered=metered)
           retry_upload(tid, end_event)
         else:
diff --git a/selfdrive/loggerd/uploader.py b/selfdrive/loggerd/uploader.py
index 4dd982a02..9e9dd0c79 100644
--- a/selfdrive/loggerd/uploader.py
+++ b/selfdrive/loggerd/uploader.py
@@ -184,7 +184,7 @@ class Uploader():
     else:
       start_time = time.monotonic()
       stat = self.normal_upload(key, fn)
-      if stat is not None and stat.status_code in (200, 201, 403, 412):
+      if stat is not None and stat.status_code in (200, 201, 401, 403, 412):
         try:
           # tag file as uploaded
           setxattr(fn, UPLOAD_ATTR_NAME, UPLOAD_ATTR_VALUE)