diff --git a/inventory_provider/tasks/worker.py b/inventory_provider/tasks/worker.py
index f338d234f38a2a4b30bcb71dc8fac49cd80b0138..9979f29ec9d3097fb72ce722b56704d337442b54 100644
--- a/inventory_provider/tasks/worker.py
+++ b/inventory_provider/tasks/worker.py
@@ -409,6 +409,7 @@ def _refresh_peers(hostname, key_base, peers):
     rp.execute()
 
 
+@log_task_entry_and_exit
 def refresh_ix_public_peers(hostname, netconf):
     _refresh_peers(
         hostname,
@@ -416,6 +417,7 @@ def refresh_ix_public_peers(hostname, netconf):
         juniper.ix_public_peers(netconf))
 
 
+@log_task_entry_and_exit
 def refresh_vpn_rr_peers(hostname, netconf):
     _refresh_peers(
         hostname,
@@ -423,6 +425,7 @@ def refresh_vpn_rr_peers(hostname, netconf):
         juniper.vpn_rr_peers(netconf))
 
 
+@log_task_entry_and_exit
 def refresh_interface_address_lookups(hostname, netconf):
     _refresh_peers(
         hostname,
@@ -430,6 +433,7 @@ def refresh_interface_address_lookups(hostname, netconf):
         juniper.interface_addresses(netconf))
 
 
+@log_task_entry_and_exit
 def refresh_juniper_interface_list(hostname, netconf):
     logger.debug(
         'removing cached netconf-interfaces for %r' % hostname)
@@ -569,6 +573,7 @@ def internal_refresh_phase_2(self):
     return self.success()
 
 
+@log_task_entry_and_exit
 def launch_refresh_cache_all(config):
     """
     utility function intended to be called outside of the worker process
@@ -664,7 +669,7 @@ def refresh_finalizer(self, pending_task_ids_json):
 
     return self.success()
 
-
+@log_task_entry_and_exit
 def _build_service_category_interface_list(update_callback=lambda s: None):
 
     def _classify(ifc):