From 592b7e6cb164b7ffcc3b4056275c917cf7f4fe2d Mon Sep 17 00:00:00 2001
From: Diggory Blake <diggsey@googlemail.com>
Date: Wed, 1 Dec 2021 18:22:43 +0000
Subject: [PATCH] Add more logging

---
 Cargo.toml               |  4 ++--
 sqlxmq_macros/Cargo.toml |  2 +-
 src/registry.rs          | 11 ++++++++++-
 3 files changed, 13 insertions(+), 4 deletions(-)

diff --git a/Cargo.toml b/Cargo.toml
index 763ff00..3aa19e5 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "sqlxmq"
-version = "0.3.3"
+version = "0.3.4"
 authors = ["Diggory Blake <diggsey@googlemail.com>"]
 edition = "2018"
 license = "MIT OR Apache-2.0"
@@ -23,7 +23,7 @@ uuid = { version = "0.8.2", features = ["v4"] }
 log = "0.4.14"
 serde_json = "1.0.64"
 serde = "1.0.124"
-sqlxmq_macros = { version = "0.3.3", path = "sqlxmq_macros" }
+sqlxmq_macros = { version = "0.3.4", path = "sqlxmq_macros" }
 anymap2 = "0.13.0"
 
 [features]
diff --git a/sqlxmq_macros/Cargo.toml b/sqlxmq_macros/Cargo.toml
index c53035e..cfa75b9 100644
--- a/sqlxmq_macros/Cargo.toml
+++ b/sqlxmq_macros/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "sqlxmq_macros"
-version = "0.3.3"
+version = "0.3.4"
 authors = ["Diggory Blake <diggsey@googlemail.com>"]
 edition = "2018"
 license = "MIT OR Apache-2.0"
diff --git a/src/registry.rs b/src/registry.rs
index 3fe6948..7342077 100644
--- a/src/registry.rs
+++ b/src/registry.rs
@@ -4,6 +4,7 @@ use std::error::Error;
 use std::fmt::Display;
 use std::future::Future;
 use std::sync::Arc;
+use std::time::Instant;
 
 use anymap2::any::CloneAnySendSync;
 use anymap2::Map;
@@ -83,7 +84,7 @@ impl JobRegistry {
 
     /// The default error handler implementation, which simply logs the error.
     pub fn default_error_handler(name: &str, error: Box<dyn Error + Send + 'static>) {
-        log::error!("Job {} failed: {}", name, error);
+        log::error!("Job `{}` failed: {}", name, error);
     }
 
     #[doc(hidden)]
@@ -94,8 +95,16 @@ impl JobRegistry {
     ) {
         let error_handler = self.error_handler.clone();
         tokio::spawn(async move {
+            let start_time = Instant::now();
+            log::info!("Job `{}` started.", name);
             if let Err(e) = f.await {
                 error_handler(name, e.into());
+            } else {
+                log::info!(
+                    "Job `{}` completed in {}s.",
+                    name,
+                    start_time.elapsed().as_secs_f64()
+                );
             }
         });
     }