Add collection name and id to opds import log messages for easier debugging.

Author: dbernstein

src/palace/manager/celery/opds.py

@@ -57,7 +57,9 @@ def opds_import_task[FeedType](
         )
 
         if not import_result:
-            task.log.info("Import failed, aborting task.")
+            task.log.info(
+                f"Import failed, aborting task for collection '{collection.name}' (id={collection.id})"
+            )
             return None
 
         # If a post-import hook is provided, call it with the import result.
@@ -81,8 +83,11 @@ def opds_import_task[FeedType](
 
     if not should_continue:
         task.log.info(
-            f"Found unchanged publications in feed, stopping import without harvesting the rest of the feed."
+            f"Found unchanged publications in feed, stopping import without harvesting the rest of the feed"
+            f" for collection '{collection.name}' (id={collection.id}) "
         )
 
-    task.log.info("Import complete.")
+    task.log.info(
+        f"Import complete for collection '{collection.name}' (id={collection.id})"
+    )
     return identifier_set

src/palace/manager/celery/tasks/opds_odl.py

@@ -345,7 +345,9 @@ def import_collection(
         )
 
     if not import_result:
-        task.log.info("Import failed, aborting task.")
+        task.log.info(
+            f"Import failed, aborting task for collection '{collection.name}' (id={collection_id})."
+        )
         return
 
     next_link = import_result.next_url
@@ -360,4 +362,6 @@ def import_collection(
             )
         )
 
-    task.log.info("Import complete.")
+    task.log.info(
+        f"Import complete for collection '{collection.name}' (id={collection_id})."
+    )

src/palace/manager/integration/license/opds/importer.py

@@ -358,7 +358,8 @@ def import_feed(
             feed = self._fetch_feed(feed_url)
         except ValueError as e:
             self.log.error(
-                f"Failed to fetch or parse the feed from '{feed_url}': {e}",
+                f"Failed to fetch or parse the feed from '{feed_url}' "
+                f"for collection '{collection.name}' (id={collection.id}): {e}",
                 exc_info=e,
             )
             return False
@@ -405,11 +406,13 @@ def import_feed(
 
         if failures:
             self.log.error(
-                f"Failed to import {len(failures)} publications from '{feed_url}'."
+                f"Failed to import {len(failures)} publications from '{feed_url}' "
+                f"for collection '{collection.name}' (id={collection.id})."
             )
             for failure in failures:
                 self.log.error(
-                    f"Failed to import publication: {failure.identifier} ({failure.title})"
+                    f"Failed to import publication: {failure.identifier} ({failure.title}) "
+                    f"for collection '{collection.name}' (id={collection.id})"
                     f" - {failure.error_message}: {failure.error}",
                     exc_info=failure.error,
                     extra={"palace_publication_data": failure.publication_data},