Skip to content

Update issue_tracker_manager.py #4788

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
wants to merge 2 commits into from
Closed

Update issue_tracker_manager.py #4788

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
0a8a9e2
Update issue_tracker_manager.py
sboni-sc May 7, 2025
405f4af
run butler format
sboni-sc May 13, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 16 additions & 2 deletions src/clusterfuzz/_internal/issue_management/jira/issue_tracker_manager.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@
import jira

from clusterfuzz._internal.config import db_config
from clusterfuzz._internal.metrics import logs


class IssueTrackerManager:
Expand Down Expand Up @@ -79,12 +80,25 @@ def _add_watchers(self, issue):
"""Add watchers to the ticket. Jira has a separate endpoint to
add watchers."""

# return if issue was not created yet
if issue.id == -1:
return

# Get watchers from LabelStore.
watchers = list(issue.ccs)

# Get existing watchers to avoid duplicate calls
existing_watchers = set(self.get_watchers(issue))

# Only add watchers that don't already exist
new_watchers = [w for w in watchers if w not in existing_watchers]

# Jira weirdness, update watchers this way.
for watcher in watchers:
self.client.add_watcher(issue.jira_issue, watcher)
for watcher in new_watchers:
try:
self.client.add_watcher(issue.jira_issue, watcher)
except Exception as e:
logs.error(f'Error adding watcher {watcher} to issue {issue.id}: {e}')

def _get_issue_fields(self, issue):
"""Get issue fields to populate the ticket"""
Expand Down
Loading