highperfocused/danswer
1
0
Fork 0
mirror of https://github.com/danswer-ai/danswer.git synced 2025-07-19 01:23:20 +02:00
Code Issues Packages Projects Releases Wiki Activity

Fix jira connector failures for server deployments

Browse Source
This commit is contained in:
Weves
2024-07-21 14:43:03 -07:00
committed by Chris Weaver
parent 6313e6d91d
commit 581ffde35a
1 changed files with 26 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
backend/danswer/connectors/danswer_jira/connector.py
View File

@ -56,6 +56,16 @@ def extract_text_from_content(content: dict) -> str:
return " ".join(texts) return " ".join(texts)
def best_effort_get_field_from_issue(jira_issue: Issue, field: str) -> Any:
if hasattr(jira_issue.fields, field):
return getattr(jira_issue.fields, field)
try:
return jira_issue.raw["fields"][field]
except Exception:
return None
def _get_comment_strs( def _get_comment_strs(
jira: Issue, comment_email_blacklist: tuple[str, ...] = () jira: Issue, comment_email_blacklist: tuple[str, ...] = ()
) -> list[str]: ) -> list[str]:
@ -117,8 +127,10 @@ def fetch_jira_issues_batch(
continue continue
comments = _get_comment_strs(jira, comment_email_blacklist) comments = _get_comment_strs(jira, comment_email_blacklist)
semantic_rep = f"{jira.fields.description}\n" + "\n".join( semantic_rep = (
[f"Comment: {comment}" for comment in comments] f"{jira.fields.description}\n"
if jira.fields.description
else "" + "\n".join([f"Comment: {comment}" for comment in comments])
) )
page_url = f"{jira_client.client_info()}/browse/{jira.key}" page_url = f"{jira_client.client_info()}/browse/{jira.key}"
@ -147,14 +159,18 @@ def fetch_jira_issues_batch(
pass pass
metadata_dict = {} metadata_dict = {}
if jira.fields.priority: priority = best_effort_get_field_from_issue(jira, "priority")
metadata_dict["priority"] = jira.fields.priority.name if priority:
if jira.fields.status: metadata_dict["priority"] = priority.name
metadata_dict["status"] = jira.fields.status.name status = best_effort_get_field_from_issue(jira, "status")
if jira.fields.resolution: if status:
metadata_dict["resolution"] = jira.fields.resolution.name metadata_dict["status"] = status.name
if jira.fields.labels: resolution = best_effort_get_field_from_issue(jira, "resolution")
metadata_dict["label"] = jira.fields.labels if resolution:
metadata_dict["resolution"] = resolution.name
labels = best_effort_get_field_from_issue(jira, "labels")
if labels:
metadata_dict["label"] = labels
doc_batch.append( doc_batch.append(
Document( Document(