1
1
import os
2
2
import sys
3
- import json
4
3
5
4
import pandas as pd
6
5
7
6
from lib .jira_conn import JiraAPIClient
8
7
from database import (
9
8
Database ,
10
- ReportJiraQARequests
9
+ # ReportJiraQARequests
11
10
)
12
11
from utils .datetime_utils import DatetimeUtils as dt
13
12
@@ -39,8 +38,9 @@ def __init__(self):
39
38
# API: Filters
40
39
def filters (self ):
41
40
query = JQL_QUERY + FILTER_ID_ALL_REQUESTS_2022 + '&fields=' \
42
- + DEFAULT_COLUMNS + ',' + STORY_POINTS + ',' + FIREFOX_RELEASE_TRAIN \
43
- + ',' + ENGINEERING_TEAM + '&' + MAX_RESULT
41
+ + DEFAULT_COLUMNS + ',' + STORY_POINTS + ',' \
42
+ + FIREFOX_RELEASE_TRAIN + ',' \
43
+ + ENGINEERING_TEAM + '&' + MAX_RESULT
44
44
45
45
return self .client .get_search (query )
46
46
@@ -69,11 +69,12 @@ def report_jira_qa_requests_payload(self, payload):
69
69
# Normalize the JSON data
70
70
df = pd .json_normalize (payload , sep = '_' )
71
71
72
- # Check if 'jira_assignee_username' exists, if not use 'alternative_assignee_emailAddress'
72
+ # Check if 'jira_assignee_username' exists
73
+ # if not use 'alternative_assignee_emailAddress'
73
74
if 'fields_assignee_emailAddress' not in df .columns :
74
- df ['fields_assignee_emailAddress' ] = df .get ('fields_assignee' , "None" )
75
+ df ['fields_assignee_emailAddress' ] = df .get ('fields_assignee' , "None" ) # noqa
75
76
else :
76
- df ['fields_assignee_emailAddress' ] = df ['fields_assignee_emailAddress' ].fillna ("Not Assigned" )
77
+ df ['fields_assignee_emailAddress' ] = df ['fields_assignee_emailAddress' ].fillna ("Not Assigned" ) # noqa
77
78
78
79
# Drop the alternative column if it exists
79
80
if 'fields_assignee' in df .columns :
@@ -92,28 +93,27 @@ def report_jira_qa_requests_payload(self, payload):
92
93
'fields_labels' : 'jira_labels'
93
94
}
94
95
95
- #Select specific columns
96
+ # Select specific columns
96
97
df_selected = df [selected_columns .keys ()]
97
98
98
99
# Rename columns
99
100
df_selected = df_selected .rename (columns = selected_columns )
100
101
101
- df_selected ['jira_created_at' ] = df_selected ['jira_created_at' ].apply (dt .convert_to_utc )
102
+ df_selected ['jira_created_at' ] = df_selected ['jira_created_at' ].apply (dt .convert_to_utc ) # noqa
102
103
103
104
# Join list of labels into a single string
104
- df_selected ['jira_labels' ] = df_selected ['jira_labels' ].apply (lambda x : ',' .join (x ) if isinstance (x , list ) else x )
105
+ df_selected ['jira_labels' ] = df_selected ['jira_labels' ].apply (lambda x : ',' .join (x ) if isinstance (x , list ) else x ) # noqa
105
106
106
107
return df_selected
107
108
108
-
109
109
def report_jira_qa_requests_insert (self , payload ):
110
110
pass
111
111
# TBD
112
112
# This is the way used in testrail.py
113
113
# report = ReportJiraQARequests(payload)
114
114
115
115
# This is the only way working locally to insert data
116
- # payload.to_sql('report_jira_qa_requests', con=engine, if_exists='append', index=False)
116
+ # payload.to_sql('report_jira_qa_requests', con=engine, if_exists='append', index=False) # noqa
117
117
118
118
# session.add(report)
119
119
# session.commit()
0 commit comments