disable schedule when the connection raise error

maestro-server · Dec 30, 2018 · 43194a9 · 43194a9
1 parent e26f24d
commit 43194a9
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/app/tasks/connections.py b/app/tasks/connections.py
@@ -38,9 +38,13 @@ def task_connections(name, _id, endpoint, source='discovery', method="GET", args
 
     if resource.get_status() < 400:
         result = resource.get_results()
-        msg = "Connection success - %s" % conn_id
+
         if result.get('found', 0) == 1:
             webhook_id = task_webhook.delay(name, _id, endpoint, source, method, args, chain)
             return {'webhook_id': webhook_id}
 
+        else:
+            msg = "Connection issue - %s" % conn_id
+            task_deplete.delay(msg, _id)
+
     return {'msg': msg, 'status_code': resource.get_status()}