adds summery node type

demo.py

@@ -29,9 +29,7 @@ def reset():
 
 
 time.sleep(5)
-set_state("dev", "pipeline_1", "step_1", "ok")
 
-set_state("prod", "pipeline_1", "step_1", "running")
 set_state("prod", "pipeline_1", "step_2", "running")
 set_state("prod", "pipeline_1", "step_3a", "running")
 set_state("prod", "pipeline_1", "step_3b", "running")
@@ -74,7 +72,7 @@ def reset():
 time.sleep(1)
 set_state("dev", "pipeline_2", "eating", "running")
 time.sleep(3)
-set_state("dev", "pipeline_2", "eating", "yes", "__FINISHED__")
+set_state("dev", "pipeline_2", "eating", "failed", "__QUIT__")
 
 time.sleep(2)
 set_state("dev", "pipeline_1", "step_4", "failed", "__QUIT__")

pipelines/demo.json

@@ -14,7 +14,8 @@
                 "links": [
                     [ "documentation", "https:\/\/github.com/jghibiki/Sydney" ]
                 ],
-                "child_pipeline": "#pipeline_2"
+                "child_pipeline": "#pipeline_2",
+                "summary": true
             }
         },
 

schema.json

@@ -32,13 +32,16 @@
         }
     ],
 
+    "failure_state": "failed",
+
     "notifications": [
         {
             "step": ".*",
             "state": "failed"
         }
     ],
 
+
     "environments": [
         "dev",
         "prod"

server/sydney.py

@@ -93,6 +93,31 @@ def notify_state_change(environment, pipeline, step, state):
 
     mongo.db.history.insert_one(state_change)
 
+    # check to see if parent is a summary node, if so update parent state
+    if "parent" in pipeline:
+        parent_pipeline, parent = get_parent(env, pipeline["parent"], pipeline["name"])
+        if(parent is not None and
+            "info" in parent and
+            "summary" in parent["info"] and
+            parent["info"]["summary"]):
+
+            # get state of all chidren of parent node
+            child_states = get_child_states(env, parent["info"]["child_pipeline"])
+
+            if child_states:
+                if pipelines["failure_state"] in child_states:
+                    # set parent to new state
+                    if pipelines["failure_state"] != parent["state"]:
+                        notify_state_change(env["name"], parent_pipeline, parent["name"], pipelines["failure_state"])
+
+
+                else:
+                    #pick most common state
+                    new_state = max(child_states, key=child_states.count)
+                    if new_state != parent["state"]:
+                        notify_state_change(env["name"], parent_pipeline, parent["name"], new_state)
+
+
     return "Updated {0} to state {1}".format(step["name"], state["name"])
 
 @app.route('/reset/<environment>/<pipeline>/<state>')
@@ -156,6 +181,43 @@ def get_environment(env_name):
             return environment
     return None
 
+def get_parent(env, parent_name, child_name):
+
+    raw_parent = parent_name[1:len(parent_name)]
+    child_name = "#"+child_name
+
+    parent_pipeline = None
+
+    for pipeline in env["pipelines"]:
+        if pipeline["name"] == raw_parent:
+            parent_pipeline = pipeline
+            break
+
+    parents = []
+    for step in parent_pipeline["steps"]:
+        if ("info" in step and "child_pipeline" in step["info"]):
+            if step["info"]["child_pipeline"] == child_name:
+                return parent_pipeline["name"], step
+
+    return None, None
+
+def get_child_states(env, pipeline_name):
+
+    pipeline_name = pipeline_name[1:len(pipeline_name)]
+
+    child_pipeline = None
+
+    for pipeline in env["pipelines"]:
+        if pipeline["name"] == pipeline_name:
+            child_pipeline = pipeline
+            break
+
+    if not child_pipeline: return None
+
+    states = [ step["state"] for step in pipeline["steps"] ]
+    return states
+
+
 
 if __name__ == '__main__':
 

server/utils.py

@@ -8,6 +8,7 @@ def load():
         schema = json.load(f)
 
     pipeline_defs["states"] = schema["states"]
+    pipeline_defs["failure_state"] = schema["failure_state"]
     pipeline_defs["root_hash"] = schema["root_hash"]
     pipeline_defs["notifications"] = schema["notifications"]
 
@@ -41,11 +42,12 @@ def load():
     for env in pipeline_defs["environments"]:
         for pipeline in env["pipelines"]:
             for step in pipeline["steps"]:
-                if "info" in step and "child_pipeline" in step["info"]:
-                    for potential_child in env["pipelines"]:
-                        if "#" + potential_child["name"] == step["info"]["child_pipeline"]:
-                            potential_child["parent"] = "#" + pipeline["name"]
-                            break
+                if "info" in step :
+                    if "child_pipeline" in step["info"]:
+                        for potential_child in env["pipelines"]:
+                            if "#" + potential_child["name"] == step["info"]["child_pipeline"]:
+                                potential_child["parent"] = "#" + pipeline["name"]
+                                break
 
     print("Loaded data", pipeline_defs)
     return pipeline_defs