diff --git a/synapse/storage/_base.py b/synapse/storage/_base.py
index 1582a58966a98d23ac1f17282a48f241034a23c2..e6eefdd6fee8275528748ab6f8ccb2eae8ffc490 100644
--- a/synapse/storage/_base.py
+++ b/synapse/storage/_base.py
@@ -503,7 +503,7 @@ class SQLBaseStore(object):
                     lock=lock
                 )
                 defer.returnValue(result)
-            except self.database_engine.IntegrityError as e:
+            except self.database_engine.module.IntegrityError as e:
                 # presumably we raced with another transaction: let's retry.
                 logger.warn(
                     "IntegrityError when upserting into %s; retrying: %s",