Apply black formatting for new black version

Author: amoghjalan

backend/analytics_server/mhq/api/deployment_analytics.py

@@ -127,9 +127,9 @@ def get_prs_included_in_deployment(deployment_id: str):
 
     repo: OrgRepo = pr_analytics_service.get_repo_by_id(deployment.repo_id)
 
-    prs: List[
-        PullRequest
-    ] = deployments_service.get_pull_requests_related_to_deployment(deployment)
+    prs: List[PullRequest] = (
+        deployments_service.get_pull_requests_related_to_deployment(deployment)
+    )
     repo_id_map = {repo.id: repo}
 
     return get_non_paginated_pr_response(
@@ -204,10 +204,10 @@ def get_team_deployment_frequency_trends(
 
     deployments_analytics_service = get_deployment_analytics_service()
 
-    week_to_deployments_count_map: Dict[
-        datetime, int
-    ] = deployments_analytics_service.get_weekly_deployment_frequency_trends(
-        team_id, interval, pr_filter, workflow_filter
+    week_to_deployments_count_map: Dict[datetime, int] = (
+        deployments_analytics_service.get_weekly_deployment_frequency_trends(
+            team_id, interval, pr_filter, workflow_filter
+        )
     )
 
     return {

backend/analytics_server/mhq/api/incidents.py

@@ -92,9 +92,9 @@ def get_deployments_with_related_incidents(
 
     incidents: List[Incident] = incident_service.get_team_incidents(team_id, interval)
 
-    deployment_incidents_map: Dict[
-        Deployment, List[Incident]
-    ] = incident_service.get_deployment_incidents_map(deployments, incidents)
+    deployment_incidents_map: Dict[Deployment, List[Incident]] = (
+        incident_service.get_deployment_incidents_map(deployments, incidents)
+    )
 
     return list(
         map(
@@ -238,10 +238,10 @@ def get_team_cfr_trends(
 
     incidents: List[Incident] = incident_service.get_team_incidents(team_id, interval)
 
-    team_weekly_change_failure_rate: Dict[
-        datetime, ChangeFailureRateMetrics
-    ] = incident_service.get_weekly_change_failure_rate(
-        interval, deployments, incidents
+    team_weekly_change_failure_rate: Dict[datetime, ChangeFailureRateMetrics] = (
+        incident_service.get_weekly_change_failure_rate(
+            interval, deployments, incidents
+        )
     )
 
     return {

backend/analytics_server/mhq/api/pull_requests.py

@@ -159,9 +159,9 @@ def get_team_lead_time_trends(
 
     lead_time_service = get_lead_time_service()
 
-    weekly_lead_time_metrics_avg_map: Dict[
-        datetime, LeadTimeMetrics
-    ] = lead_time_service.get_team_lead_time_metrics_trends(team, interval, pr_filter)
+    weekly_lead_time_metrics_avg_map: Dict[datetime, LeadTimeMetrics] = (
+        lead_time_service.get_team_lead_time_metrics_trends(team, interval, pr_filter)
+    )
 
     return {
         week.isoformat(): adapt_lead_time_metrics(average_lead_time_metrics)

backend/analytics_server/mhq/api/resources/incident_resources.py

@@ -22,12 +22,14 @@ def adapt_incident(
         "provider": incident.provider,
         "status": incident.status,
         "creation_date": incident.creation_date.isoformat(),
-        "resolved_date": incident.resolved_date.isoformat()
-        if incident.resolved_date
-        else None,
-        "acknowledged_date": incident.acknowledged_date.isoformat()
-        if incident.acknowledged_date
-        else None,
+        "resolved_date": (
+            incident.resolved_date.isoformat() if incident.resolved_date else None
+        ),
+        "acknowledged_date": (
+            incident.acknowledged_date.isoformat()
+            if incident.acknowledged_date
+            else None
+        ),
         "assigned_to": adapt_user_info(incident.assigned_to, username_user_map),
         "assignees": list(
             map(

backend/analytics_server/mhq/exapi/git_incidents.py

@@ -40,10 +40,10 @@ def get_org_repo(self, repo_id: str):
     def get_repo_revert_prs_in_interval(
         self, repo_id: str, from_time: datetime, to_time: datetime
     ) -> List[RevertPRMap]:
-        revert_pr_mappings: List[
-            PullRequestRevertPRMapping
-        ] = self.code_repo_service.get_repo_revert_prs_mappings_updated_in_interval(
-            repo_id, from_time, to_time
+        revert_pr_mappings: List[PullRequestRevertPRMapping] = (
+            self.code_repo_service.get_repo_revert_prs_mappings_updated_in_interval(
+                repo_id, from_time, to_time
+            )
         )
 
         revert_pr_ids = [str(pr.pr_id) for pr in revert_pr_mappings]

backend/analytics_server/mhq/service/code/integration.py

@@ -13,10 +13,10 @@ def __init__(self, core_repo_service: CoreRepoService):
         self.core_repo_service = core_repo_service
 
     def get_org_providers(self, org_id: str) -> List[str]:
-        integrations: List[
-            Integration
-        ] = self.core_repo_service.get_org_integrations_for_names(
-            org_id, CODE_INTEGRATION_BUCKET
+        integrations: List[Integration] = (
+            self.core_repo_service.get_org_integrations_for_names(
+                org_id, CODE_INTEGRATION_BUCKET
+            )
         )
         if not integrations:
             return []

backend/analytics_server/mhq/service/code/lead_time.py

@@ -54,15 +54,15 @@ def get_team_lead_time_metrics_trends(
             set(self._get_team_repos_lead_time_metrics(team_repos, interval, pr_filter))
         )
 
-        weekly_lead_time_metrics_map: Dict[
-            datetime, List[LeadTimeMetrics]
-        ] = generate_expanded_buckets(
-            lead_time_metrics, interval, "merged_at", "weekly"
+        weekly_lead_time_metrics_map: Dict[datetime, List[LeadTimeMetrics]] = (
+            generate_expanded_buckets(
+                lead_time_metrics, interval, "merged_at", "weekly"
+            )
         )
 
-        weekly_lead_time_metrics_avg_map: Dict[
-            datetime, LeadTimeMetrics
-        ] = self.get_avg_lead_time_metrics_from_map(weekly_lead_time_metrics_map)
+        weekly_lead_time_metrics_avg_map: Dict[datetime, LeadTimeMetrics] = (
+            self.get_avg_lead_time_metrics_from_map(weekly_lead_time_metrics_map)
+        )
 
         weekly_lead_time_metrics_avg_map = fill_missing_week_buckets(
             weekly_lead_time_metrics_avg_map, interval, LeadTimeMetrics
@@ -176,10 +176,10 @@ def _get_lead_time_prs_for_repos_using_workflow_deployments(
         pr_filter: PRFilter = None,
     ) -> List[PullRequest]:
 
-        team_repos_with_workflow_deployments_configured: List[
-            TeamRepos
-        ] = self._deployments_service.get_filtered_team_repos_with_workflow_configured_deployments(
-            team_repos
+        team_repos_with_workflow_deployments_configured: List[TeamRepos] = (
+            self._deployments_service.get_filtered_team_repos_with_workflow_configured_deployments(
+                team_repos
+            )
         )
 
         repo_ids = [
@@ -214,9 +214,11 @@ def _get_lead_time_prs_for_repos_using_pr_deployments(
 
     def _get_lead_time_metrics_for_pr(self, pr: PullRequest) -> LeadTimeMetrics:
         return LeadTimeMetrics(
-            first_commit_to_open=pr.first_commit_to_open
-            if pr.first_commit_to_open is not None and pr.first_commit_to_open > 0
-            else 0,
+            first_commit_to_open=(
+                pr.first_commit_to_open
+                if pr.first_commit_to_open is not None and pr.first_commit_to_open > 0
+                else 0
+            ),
             first_response_time=pr.first_response_time if pr.first_response_time else 0,
             rework_time=pr.rework_time if pr.rework_time else 0,
             merge_time=pr.merge_time if pr.merge_time else 0,

backend/analytics_server/mhq/service/code/repository_service.py

@@ -194,9 +194,9 @@ def _adapt_org_incident_service(
             name=org_repo.name,
             key=str(org_repo.id),
             meta={},
-            created_at=org_incident_service.created_at
-            if org_incident_service
-            else time_now(),
+            created_at=(
+                org_incident_service.created_at if org_incident_service else time_now()
+            ),
             updated_at=time_now(),
             source_type=IncidentSource.GIT_REPO,
         )

backend/analytics_server/mhq/service/code/sync/etl_code_analytics.py

@@ -92,9 +92,11 @@ def get_pr_performance(pr: PullRequest, pr_events: [PullRequestEvent]):
             cycle_time = cycle_time.total_seconds()
 
         return PRPerformance(
-            first_review_time=(first_review.created_at - pr.created_at).total_seconds()
-            if first_review
-            else -1,
+            first_review_time=(
+                (first_review.created_at - pr.created_at).total_seconds()
+                if first_review
+                else -1
+            ),
             rework_time=rework_time,
             merge_time=merge_time,
             cycle_time=cycle_time if pr.state == PullRequestState.MERGED else -1,

backend/analytics_server/mhq/service/code/sync/etl_github_handler.py

@@ -166,9 +166,9 @@ def process_pr(
         pr_model: Optional[PullRequest] = self.code_repo_service.get_repo_pr_by_number(
             repo_id, pr.number
         )
-        pr_event_model_list: List[
-            PullRequestEvent
-        ] = self.code_repo_service.get_pr_events(pr_model)
+        pr_event_model_list: List[PullRequestEvent] = (
+            self.code_repo_service.get_pr_events(pr_model)
+        )
         pr_commits_model_list: List = []
 
         reviews: List[GithubPullRequestReview] = list(self._api.get_pr_reviews(pr))
@@ -340,9 +340,11 @@ def _to_pr_commits(
                     url=commit["html_url"],
                     data=commit,
                     message=commit["commit"]["message"],
-                    author=commit["author"]["login"]
-                    if commit.get("author")
-                    else commit["commit"].get("committer", {}).get("email", ""),
+                    author=(
+                        commit["author"]["login"]
+                        if commit.get("author")
+                        else commit["commit"].get("committer", {}).get("email", "")
+                    ),
                     created_at=self._dt_from_github_dt_string(
                         commit["commit"]["committer"]["date"]
                     ),