Allow app to track callback change

appdaemon/adbase.py

@@ -107,6 +107,7 @@ def __init__(self, ad: "AppDaemon", config_model: "AppConfig"):
 
         self.namespace = "default"
         self.dashboard_dir = None
+        self.callback_counter = 0
 
         if self.AD.http is not None:
             self.dashboard_dir = self.AD.http.dashboard_dir

appdaemon/threads.py

@@ -976,6 +976,7 @@ async def async_worker(self, args):  # noqa: C901
                 async def safe_callback():
                     """Wraps actually calling the function for the callback with logic to transform exceptions based
                     on the callback type"""
+                    increment_callback_counter(app, name)
                     try:
                         await funcref()
                     except Exception as exc:
@@ -1069,6 +1070,7 @@ def worker(self):  # noqa: C901
                     def safe_callback():
                         """Wraps actually calling the function for the callback with logic to transform exceptions based
                         on the callback type"""
+                        increment_callback_counter(app, name)
                         try:
                             funcref()
                         except Exception as exc:
@@ -1169,3 +1171,17 @@ def report_callback_sig(self, name, type, funcref, args):
                     "Logged an error to %s",
                     self.AD.logging.get_filename("error_log"),
                 )
+
+def increment_callback_counter(app, name):
+    try:
+        # This function may be called concurrently and the GIL won't protect us against
+        # races during app.callback_counter += 1 so we need to use a lock. We'll just use that of the app.
+        with app.lock:
+            app.callback_counter += 1
+    except Exception:
+        error_logger = logging.getLogger("Error.{}".format(name))
+        error_logger.warning("-" * 60)
+        error_logger.warning("Unexpected error in worker for App %s:", name)
+        error_logger.warning("-" * 60)
+        error_logger.warning(traceback.format_exc())
+        error_logger.warning("-" * 60)