Restore error instrumentation

Signed-off-by: Jim Crossley <[email protected]>

Author: jcrossley3

modules/importer/src/runner/common/walker/git.rs

@@ -173,7 +173,7 @@ where
     }
 
     /// Sync version, as all git functions are sync
-    #[instrument(skip(self))]
+    #[instrument(skip(self), err)]
     fn run_sync(self) -> Result<Continuation, Error> {
         log::debug!("Starting run for: {}", self.source);
 
@@ -282,7 +282,7 @@ where
         }
     }
 
-    #[instrument(skip(self))]
+    #[instrument(skip(self), err)]
     fn clone_repo(&self, path: &Path) -> Result<Repository, git2::Error> {
         self.progress
             .message_sync(format!("Cloning repository: {}", self.source));

modules/importer/src/runner/csaf/mod.rs

@@ -29,7 +29,7 @@ use url::Url;
 use walker_common::fetcher::{Fetcher, FetcherOptions};
 
 impl super::ImportRunner {
-    #[instrument(skip_all)]
+    #[instrument(skip_all, err)]
     pub async fn run_once_csaf(
         &self,
         context: impl RunContext,

modules/importer/src/runner/cve/mod.rs

@@ -70,7 +70,7 @@ impl<C: RunContext> Callbacks<Vec<u8>> for Context<C> {
 }
 
 impl super::ImportRunner {
-    #[instrument(skip(self, context))]
+    #[instrument(skip(self, context), err)]
     pub async fn run_once_cve(
         &self,
         context: impl RunContext + 'static,

modules/importer/src/runner/osv/mod.rs

@@ -97,7 +97,7 @@ impl<C: RunContext> Callbacks<Vec<u8>> for Context<C> {
 }
 
 impl super::ImportRunner {
-    #[instrument(skip(self, context))]
+    #[instrument(skip(self, context), err)]
     pub async fn run_once_osv(
         &self,
         context: impl RunContext + 'static,

modules/importer/src/runner/sbom/mod.rs

@@ -28,7 +28,7 @@ use url::Url;
 use walker_common::fetcher::{Fetcher, FetcherOptions};
 
 impl super::ImportRunner {
-    #[instrument(skip_all)]
+    #[instrument(skip_all, err)]
     pub async fn run_once_sbom(
         &self,
         context: impl RunContext,

modules/importer/src/service.rs

@@ -247,7 +247,7 @@ impl ImporterService {
         .await
     }
 
-    #[instrument(skip(self, report, continuation))]
+    #[instrument(skip(self, report, continuation), err)]
     pub async fn update_finish(
         &self,
         name: &str,

modules/ingestor/src/graph/advisory/advisory_vulnerability.rs

@@ -45,7 +45,7 @@ impl AdvisoryVulnerabilityContext<'_> {
         )
     }
 
-    #[instrument(skip(self, connection))]
+    #[instrument(skip(self, connection), err)]
     pub async fn ingest_package_status<C: ConnectionTrait>(
         &self,
         cpe_context: Option<Cpe>,