diff --git a/onadata/apps/api/viewsets/connect_viewset.py b/onadata/apps/api/viewsets/connect_viewset.py
index 65750a6e4a..aa3a9f87ba 100644
--- a/onadata/apps/api/viewsets/connect_viewset.py
+++ b/onadata/apps/api/viewsets/connect_viewset.py
@@ -9,6 +9,7 @@
 from rest_framework.exceptions import ParseError
 from rest_framework.response import Response
 from rest_framework import mixins
+from multidb.pinning import use_master
 
 from onadata.apps.api.models.odk_token import ODKToken
 from onadata.apps.api.models.temp_token import TempToken
@@ -46,8 +47,8 @@ def user_profile_w_token_response(request, status):
     except UserProfile.DoesNotExist:
         user_profile = cache.get(
             f'{USER_PROFILE_PREFIX}{request.user.username}')
-        if not user_profile:
-            user_profile, __ = UserProfile.objects.get_or_create(
+        with use_master:
+            user_profile, _ = UserProfile.objects.get_or_create(
                 user=request.user)
             cache.set(
                 f'{USER_PROFILE_PREFIX}{request.user.username}',