File tree 3 files changed +23
-19
lines changed
backend/analytics_server/mhq
3 files changed +23
-19
lines changed Original file line number Diff line number Diff line change @@ -168,6 +168,7 @@ def get_team_lead_time_trends(
168
168
for week , average_lead_time_metrics in weekly_lead_time_metrics_avg_map .items ()
169
169
}
170
170
171
+
171
172
@app .route ("/teams/<team_id>/prs/merged_without_review" , methods = {"GET" })
172
173
@queryschema (
173
174
Schema (
@@ -177,16 +178,11 @@ def get_team_lead_time_trends(
177
178
}
178
179
),
179
180
)
180
- def merged_without_review (
181
- team_id : str ,
182
- from_time : datetime ,
183
- to_time : datetime
184
- ):
181
+ def merged_without_review (team_id : str , from_time : datetime , to_time : datetime ):
185
182
query_validator = get_query_validator ()
186
183
team : Team = query_validator .team_validator (team_id )
187
184
interval : Interval = query_validator .interval_validator (from_time , to_time )
188
185
pr_analytics = get_pr_analytics_service ()
189
- result = pr_analytics .get_prs_merged_without_review (team .id ,interval )
186
+ result = pr_analytics .get_prs_merged_without_review (team .id , interval )
190
187
prs_map = [pr .id for pr in result ]
191
- return {'PrsWithoutReviewMerged' : prs_map }
192
-
188
+ return {"PrsWithoutReviewMerged" : prs_map }
Original file line number Diff line number Diff line change 2
2
from mhq .store .repos .code import CodeRepoService
3
3
4
4
5
- from typing import List ,Optional
5
+ from typing import List , Optional
6
6
from mhq .utils .time import Interval
7
7
8
8
@@ -12,9 +12,11 @@ def __init__(self, code_repo_service: CodeRepoService):
12
12
13
13
def get_prs_by_ids (self , pr_ids : List [str ]) -> List [PullRequest ]:
14
14
return self .code_repo_service .get_prs_by_ids (pr_ids )
15
-
16
- def get_prs_merged_without_review (self ,team_id :str ,interval :Interval ) -> List [PullRequest ]:
17
- return self .code_repo_service .get_prs_merged_without_review (team_id ,interval )
15
+
16
+ def get_prs_merged_without_review (
17
+ self , team_id : str , interval : Interval
18
+ ) -> List [PullRequest ]:
19
+ return self .code_repo_service .get_prs_merged_without_review (team_id , interval )
18
20
19
21
def get_team_repos (self , team_id : str ) -> List [OrgRepo ]:
20
22
return self .code_repo_service .get_team_repos (team_id )
Original file line number Diff line number Diff line change @@ -346,16 +346,22 @@ def get_team_repos(self, team_id) -> List[OrgRepo]:
346
346
347
347
team_repo_ids = [tr .org_repo_id for tr in team_repos ]
348
348
return self .get_repos_by_ids (team_repo_ids )
349
-
349
+
350
350
@rollback_on_exc
351
- def get_prs_merged_without_review (self ,team_id ,interval ) -> List [PullRequest ]:
351
+ def get_prs_merged_without_review (self , team_id , interval ) -> List [PullRequest ]:
352
352
AllOrg = self .get_team_repos (team_id )
353
353
AllOrg_ids = [tr .id for tr in AllOrg ]
354
- return (self ._db .session .query (PullRequest )
355
- .filter (PullRequest .repo_id .in_ (AllOrg_ids ))
356
- .filter (PullRequest .merge_time == None )
357
- .filter (PullRequest .created_in_db_at .between (interval .from_time ,interval .to_time ))
358
- .all ())
354
+ return (
355
+ self ._db .session .query (PullRequest )
356
+ .filter (PullRequest .repo_id .in_ (AllOrg_ids ))
357
+ .filter (PullRequest .merge_time == None )
358
+ .filter (
359
+ PullRequest .created_in_db_at .between (
360
+ interval .from_time , interval .to_time
361
+ )
362
+ )
363
+ .all ()
364
+ )
359
365
360
366
@rollback_on_exc
361
367
def get_team_repos_by_team_id (self , team_id : str ) -> List [TeamRepos ]:
You can’t perform that action at this time.
0 commit comments