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 a113fd8e2..e695967c8 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,8 @@ 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)