diff --git a/billing/tasks.py b/billing/tasks.py
index 5136c7d..6c26cb1 100644
--- a/billing/tasks.py
+++ b/billing/tasks.py
@@ -16,7 +16,7 @@ logger = logging.getLogger(__name__)
 @app.task
 def update_expired_topups(timestamp: int):
     expired_topups_qs = Topup.objects.filter(
-        expires_at__lte=timezone.now(), expiry_notification_sent=False
+        expires_at__lte=timezone.now(), expiry_notification_sent=False, paid=False
     ).select_related("user")
 
     with transaction.atomic():