fix: docker scripts

Author: giancarloromeo

services/notifications/docker/boot.sh

@@ -47,7 +47,7 @@ APP_LOG_LEVEL=${LOGLEVEL:-${LOG_LEVEL:-${LOGLEVEL:-INFO}}}
 SERVER_LOG_LEVEL=$(echo "${APP_LOG_LEVEL}" | tr '[:upper:]' '[:lower:]')
 echo "$INFO" "Log-level app/server: $APP_LOG_LEVEL/$SERVER_LOG_LEVEL"
 
-if [ "${NOTIFICATIONS_WORKER_MODE}" = "true" ]; then
+if [ "${NOTIFICATIONS_WORKER_MODE:-}" = "true" ]; then
   if [ "${SC_BOOT_MODE}" = "debug" ]; then
     exec watchmedo auto-restart \
       --directory /devel/packages \

services/notifications/docker/healthcheck.py

@@ -16,18 +16,50 @@
         - SEE https://blog.sixeyed.com/docker-healthchecks-why-not-to-use-curl-or-iwr/
 """
 import os
+import subprocess
 import sys
 from urllib.request import urlopen
 
+from simcore_service_notifications.core.application import ApplicationSettings
+
 SUCCESS, UNHEALTHY = 0, 1
 
-# Disabled if boots with debugger (e.g. debug, pdb-debug, debug-ptvsd, debugpy, etc)
-ok = "debug" in os.environ.get("SC_BOOT_MODE", "").lower()
+# Disabled if boots with debugger
+ok = os.getenv("SC_BOOT_MODE", "").lower() == "debug"
 
 # Queries host
 # pylint: disable=consider-using-with
+
+app_settings = ApplicationSettings.create_from_envs()
+
+
+def _is_celery_worker_healthy():
+    assert app_settings.NOTIFICATIONS_CELERY
+    broker_url = app_settings.NOTIFICATIONS_CELERY.CELERY_RABBIT_BROKER.dsn
+
+    try:
+        result = subprocess.run(
+            [
+                "celery",
+                "--broker",
+                broker_url,
+                "inspect",
+                "ping",
+                "--destination",
+                "celery@" + os.getenv("NOTIFICATIONS_WORKER_NAME", "worker"),
+            ],
+            capture_output=True,
+            text=True,
+            check=True,
+        )
+        return "pong" in result.stdout
+    except subprocess.CalledProcessError:
+        return False
+
+
 ok = (
     ok
+    or (app_settings.NOTIFICATIONS_WORKER_MODE and _is_celery_worker_healthy())
     or urlopen(
         "{host}{baseurl}".format(
             host=sys.argv[1], baseurl=os.environ.get("SIMCORE_NODE_BASEPATH", "")