application: adjust logging

Author: shtrom

git_hg_sync/application.py

@@ -37,7 +37,9 @@ def signal_handler(_sig: int, _frame: FrameType | None) -> None:
         self._worker.run()
 
     def _handle_push_event(self, push_event: Push) -> None:
-        logger.info(f"Handling push event: {push_event.pushid}")
+        logger.debug(
+            f"Handling push event: {push_event.pushid} for {push_event.repo_url}"
+        )
         synchronizer = self._repo_synchronizers[push_event.repo_url]
         operations_by_destination: dict[str, list[SyncOperation]] = {}
 
@@ -56,10 +58,13 @@ def _handle_push_event(self, push_event: Push) -> None:
                     f"Failed to process operations: {destination=} {operations=} {exc=}"
                 )
                 raise exc
+        logger.info(
+            f"Successfully handled event: {push_event.pushid} for {push_event.repo_url}"
+        )
 
     def _handle_event(self, event: Push | Tag) -> None:
         if event.repo_url not in self._repo_synchronizers:
-            logger.info(f"Ignoring event for untracked repository: {event.repo_url}")
+            logger.warning(f"Ignoring event for untracked repository: {event.repo_url}")
             return
         match event:
             case Push():

git_hg_sync/repo_synchronizer.py

@@ -52,6 +52,7 @@ def _fetch_all_from_remote(self, repo: Repo, remote: str) -> None:
                 raise e
 
     def sync(self, destination_url: str, operations: list[SyncOperation]) -> None:
+        logger.debug(f"Syncing {operations} to {destination_url}")
         repo = self._get_clone_repo()
         destination_remote = f"hg::{destination_url}"
 
@@ -69,9 +70,12 @@ def sync(self, destination_url: str, operations: list[SyncOperation]) -> None:
             op for op in operations if isinstance(op, SyncBranchOperation)
         ]
         for branch_operation in branch_ops:
-            push_args.append(
-                f"{branch_operation.source_commit}:refs/heads/branches/{branch_operation.destination_branch}/tip"
-            )
+            try:
+                push_args.append(
+                    f"{branch_operation.source_commit}:refs/heads/branches/{branch_operation.destination_branch}/tip"
+                )
+            except Exception as e:
+                raise RepoSyncError(branch_operation, e) from e
 
         # Add mercurial metadata to new commits from synced branches
         # Some of these commits could be tagged in the same synchronization and
@@ -104,16 +108,20 @@ def sync(self, destination_url: str, operations: list[SyncOperation]) -> None:
             if not self._commit_has_mercurial_metadata(
                 repo, tag_operation.source_commit
             ):
-                raise MercurialMetadataNotFoundError()
-            repo.git.cinnabar(
-                [
-                    "tag",
-                    "--onto",
-                    f"refs/heads/{tag_operation.tags_destination_branch}",
-                    tag_operation.tag,
-                    tag_operation.source_commit,
-                ]
-            )
-
+                raise MercurialMetadataNotFoundError(tag_operation)
+            try:
+                repo.git.cinnabar(
+                    [
+                        "tag",
+                        "--onto",
+                        f"refs/heads/{tag_operation.tags_destination_branch}",
+                        tag_operation.tag,
+                        tag_operation.source_commit,
+                    ]
+                )
+            except Exception as e:
+                raise RepoSyncError(tag_operation, e) from e
+
+        logger.debug(f"Push arguments: {push_args}")
         # Push commits, branches and tags to destination
         repo.git.push(*push_args)