Add environment variable for slack webhook failures_only (#48)

Add SENSORSAFRICA_CELERY_SLACK_WEBHOOK_FAILURES_ONLY environment variable for slack webhook failures_only option
CodeForAfrica · Sep 10, 2019 · 255b49d · 255b49d
1 parent ae7e3b6
commit 255b49d
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/sensorsafrica/celeryapp.py b/sensorsafrica/celeryapp.py
@@ -16,4 +16,10 @@
 # Autodiscover tasks in tasks.py
 app.autodiscover_tasks()
 
-slack_app = Slackify(app, os.environ.get("SENSORSAFRICA_CELERY_SLACK_WEBHOOK", ""))
+SLACK_WEBHOOK = os.environ.get("SENSORSAFRICA_CELERY_SLACK_WEBHOOK", "")
+SLACK_WEBHOOK_FAILURES_ONLY = os.environ.get(
+    "SENSORSAFRICA_CELERY_SLACK_WEBHOOK_FAILURES_ONLY", "").strip().lower() in ('true', 't', '1')
+
+options = {'failures_only': SLACK_WEBHOOK_FAILURES_ONLY}
+
+slack_app = Slackify(app, SLACK_WEBHOOK, **options)