diff --git a/cmd/apollo-worker-notifications/main.go b/cmd/apollo-worker-notifications/main.go
index 9678610..2b6fb0e 100644
--- a/cmd/apollo-worker-notifications/main.go
+++ b/cmd/apollo-worker-notifications/main.go
@@ -267,6 +267,10 @@ func (c *Consumer) Consume(delivery rmq.Delivery) {
 			}).Error("failed to refresh reddit tokens")
 			return
 		}
+
+		// Refresh client
+		rac = c.reddit.NewAuthenticatedClient(tokens.RefreshToken, tokens.AccessToken)
+
 		err = c.pool.BeginFunc(ctx, func(tx pgx.Tx) error {
 			stmt := `
 				UPDATE accounts