added task logging for failed netconf load

inventory_provider/tasks/worker.py

@@ -1264,7 +1264,9 @@ def reload_lab_router_config_chorded(self, hostname):
 @log_task_entry_and_exit
 def reload_router_config_chorded(self, hostname):
     self.log_info(f'loading netconf data for {hostname} RL')
-    netconf_str = retrieve_and_persist_netconf_config(hostname)
+    netconf_str = retrieve_and_persist_netconf_config(
+        hostname, self.log_warning)
+
     netconf_doc = etree.fromstring(netconf_str)
 
     # clear cached classifier responses for this router, and
@@ -1291,7 +1293,8 @@ def reload_router_config_chorded(self, hostname):
 
 
 # new
-def retrieve_and_persist_netconf_config(hostname, lab=False):
+def retrieve_and_persist_netconf_config(
+        hostname, lab=False, update_callback=lambda s: None):
     redis_key = f'netconf:{hostname}'
     if lab:
         redis_key = f'lab:{redis_key}'
@@ -1303,6 +1306,7 @@ def retrieve_and_persist_netconf_config(hostname, lab=False):
     except (ConnectionError, juniper.NetconfHandlingError):
         msg = f'error loading netconf data from {hostname}'
         logger.exception(msg)
+        update_callback(msg)
         r = get_current_redis(InventoryTask.config)
 
         netconf_str = r.get(redis_key)
@@ -1311,6 +1315,7 @@ def retrieve_and_persist_netconf_config(hostname, lab=False):
                 f'netconf error with {hostname}'
                 f' and no cached netconf data found')
         logger.info(f'Returning cached netconf data for {hostname}')
+        update_callback(f'Returning cached netconf data for {hostname}')
 
     r = get_next_redis(InventoryTask.config)
     r.set(redis_key, netconf_str)