@@ -92,19 +92,36 @@ def _handle_assign(
9292 users_by_id = {user .id : user for user in users }
9393 projects_by_user = Project .objects .get_by_users (users )
9494
95+ logger = logging .getLogger (f"sentry.integrations.{ integration .provider } " )
96+
9597 for group in affected_groups :
9698 if not should_sync_assignee_inbound (group .organization , integration .provider ):
9799 continue
98100
99101 user_id = _get_user_id (projects_by_user , group )
100102 user = users_by_id .get (user_id ) if user_id is not None else None
101103 if user :
104+ logger .info (
105+ "sync_group_assignee_inbound._handle_assign.assigning.group" ,
106+ extra = {
107+ "group_id" : group .id ,
108+ "user_id" : user .id ,
109+ },
110+ )
102111 GroupAssignee .objects .assign (
103112 group ,
104113 user ,
105114 assignment_source = AssignmentSource .from_integration (integration ),
106115 )
107116 groups_assigned .append (group )
117+ else :
118+ logger .info (
119+ "sync_group_assignee_inbound._handle_assign.user_not_found" ,
120+ extra = {
121+ "group_id" : group .id ,
122+ "user_id" : user_id ,
123+ },
124+ )
108125
109126 return groups_assigned
110127
@@ -128,6 +145,7 @@ def sync_group_assignee_inbound_by_external_actor(
128145 "external_user_name" : external_user_name ,
129146 "issue_key" : external_issue_key ,
130147 "method" : AssigneeInboundSyncMethod .EXTERNAL_ACTOR .value ,
148+ "assign" : assign ,
131149 }
132150
133151 if not affected_groups :
@@ -147,11 +165,16 @@ def sync_group_assignee_inbound_by_external_actor(
147165 user_ids = [
148166 external_actor for external_actor in external_actors if external_actor is not None
149167 ]
168+ log_context ["user_ids" ] = user_ids
169+ logger .info ("sync_group_assignee_inbound_by_external_actor.user_ids" , extra = log_context )
170+
150171 users = user_service .get_many_by_id (ids = user_ids )
151172
152173 groups_assigned = _handle_assign (affected_groups , integration , users )
153174
154175 if len (groups_assigned ) != len (affected_groups ):
176+ log_context ["groups_assigned_count" ] = len (groups_assigned )
177+ log_context ["affected_groups_count" ] = len (affected_groups )
155178 lifecycle .record_halt (
156179 ProjectManagementHaltReason .SYNC_INBOUND_ASSIGNEE_NOT_FOUND , extra = log_context
157180 )
@@ -183,6 +206,7 @@ def sync_group_assignee_inbound(
183206 "email" : email ,
184207 "issue_key" : external_issue_key ,
185208 "method" : AssigneeInboundSyncMethod .EMAIL .value ,
209+ "assign" : assign ,
186210 }
187211 if not affected_groups :
188212 logger .info ("no-affected-groups" , extra = log_context )
0 commit comments