@@ -107,7 +107,7 @@ def save(self, user_profile: dict[str, Any]) -> None:
107
107
pass
108
108
109
109
class UserProfileTracker :
110
- def __init__ (self , user_id : str , user_profile_service : UserProfileService , logger :Optional [_logging .Logger ] = None ):
110
+ def __init__ (self , user_id : str , user_profile_service : Optional [ UserProfileService ] , logger :Optional [_logging .Logger ] = None ):
111
111
self .user_id = user_id
112
112
self .user_profile_service = user_profile_service
113
113
self .logger = _logging .adapt_logger (logger or _logging .NoOpLogger ())
@@ -120,11 +120,11 @@ def get_user_profile(self):
120
120
def load_user_profile (self , reasons : Optional [list [str ]]= [], error_handler : Optional [BaseErrorHandler ]= None ):
121
121
reasons = reasons if reasons else []
122
122
try :
123
- user_profile = self .user_profile_service .lookup (self .user_id )
123
+ user_profile = self .user_profile_service .lookup (self .user_id ) if self . user_profile_service else None
124
124
if user_profile is None :
125
125
message = "Unable to get a user profile from the UserProfileService."
126
126
reasons .append (message )
127
- self .logger .info (message )
127
+ # self.logger.info(message)
128
128
else :
129
129
if 'user_id' in user_profile and 'experiment_bucket_map' in user_profile :
130
130
self .user_profile = UserProfile (
@@ -167,8 +167,9 @@ def save_user_profile(self, error_handler: Optional[BaseErrorHandler] = None):
167
167
if not self .profile_updated :
168
168
return
169
169
try :
170
- self .user_profile_service .save (self .user_profile .__dict__ )
171
- self .logger .info (f'Saved user profile of user "{ self .user_profile .user_id } ".' )
170
+ if self .user_profile_service :
171
+ self .user_profile_service .save (self .user_profile .__dict__ )
172
+ self .logger .info (f'Saved user profile of user "{ self .user_profile .user_id } ".' )
172
173
except Exception as exception :
173
174
self .logger .warning (f'Failed to save user profile of user "{ self .user_profile .user_id } ".' )
174
175
# error_handler.handle_error(exception)
0 commit comments