From 865a73f582c6f84ae4fa4877967717a7f70f76c7 Mon Sep 17 00:00:00 2001 From: Suejung Shin Date: Tue, 18 Mar 2025 19:49:49 -0700 Subject: [PATCH 1/2] chore: Trigger overwatch --- tasks/sync_repos.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/tasks/sync_repos.py b/tasks/sync_repos.py index a113fd8e2..31d49a865 100644 --- a/tasks/sync_repos.py +++ b/tasks/sync_repos.py @@ -5,14 +5,13 @@ from asgiref.sync import async_to_sync from celery.exceptions import SoftTimeLimitExceeded from redis.exceptions import LockError -from shared.celery_config import ( - sync_repo_languages_gql_task_name, - sync_repo_languages_task_name, - sync_repos_task_name, -) +from shared.celery_config import (sync_repo_languages_gql_task_name, + sync_repo_languages_task_name, + sync_repos_task_name) from shared.config import get_config from shared.torngit.base import TorngitBaseAdapter -from shared.torngit.exceptions import TorngitClientError, TorngitServerFailureError +from shared.torngit.exceptions import (TorngitClientError, + TorngitServerFailureError) from sqlalchemy import and_ from sqlalchemy.orm.session import Session @@ -480,6 +479,7 @@ def upsert_owner( "Upserting owner", extra=dict(git_service=service, service_id=service_id, username=username), ) + print("trigger overwatch") owner = ( db_session.query(Owner) .filter(Owner.service == service, Owner.service_id == service_id) From cf9110650ecf854b2379300863ab30d4d79fa8d9 Mon Sep 17 00:00:00 2001 From: Suejung Shin Date: Tue, 18 Mar 2025 20:45:26 -0700 Subject: [PATCH 2/2] trigger ovewatch --- services/notification/notifiers/generics.py | 12 +++++------- tasks/sync_repos.py | 1 + 2 files changed, 6 insertions(+), 7 deletions(-) diff --git a/services/notification/notifiers/generics.py b/services/notification/notifiers/generics.py index fef7d7f3a..5bc414bca 100644 --- a/services/notification/notifiers/generics.py +++ b/services/notification/notifiers/generics.py @@ -12,10 +12,8 @@ from helpers.metrics import metrics from services.comparison import ComparisonProxy from services.comparison.types import Comparison -from services.notification.notifiers.base import ( - AbstractBaseNotifier, - NotificationResult, -) +from services.notification.notifiers.base import (AbstractBaseNotifier, + NotificationResult) from services.urls import get_commit_url, get_pull_url from services.yaml.reader import get_paths_from_flags, round_number @@ -159,9 +157,9 @@ def generate_compare_dict(self, comparison: Comparison): head_full_commit = comparison.head base_full_commit = comparison.project_coverage_base if comparison.has_project_coverage_base_report(): - difference = Decimal(head_full_commit.report.totals.coverage) - Decimal( - base_full_commit.report.totals.coverage - ) + head_full_commit_coverage: int | None = head_full_commit.report.totals.coverage + base_full_commit_coverage: int | None = base_full_commit.report.totals.coverage + difference = Decimal(head_full_commit_coverage) - Decimal(base_full_commit_coverage) message = ( "no change" if difference == 0 diff --git a/tasks/sync_repos.py b/tasks/sync_repos.py index 31d49a865..e695967c8 100644 --- a/tasks/sync_repos.py +++ b/tasks/sync_repos.py @@ -480,6 +480,7 @@ def upsert_owner( extra=dict(git_service=service, service_id=service_id, username=username), ) print("trigger overwatch") + owner = ( db_session.query(Owner) .filter(Owner.service == service, Owner.service_id == service_id)