feat: depends_on flag excepts multiple dependencies for each process now

Author: Michael Hammann

supervisor/process.py

@@ -196,8 +196,10 @@ def spawn(self):
         Return the process id.  If the fork() call fails, return None.
         """
         # check if the process is dependent upon any other process and if so make sure that one is in the RUNNING state
-        if self.config.depends_on is not None and self.config.depends_on.state not in RUNNING_STATES:
-            self.config.depends_on.spawn()
+        if self.config.depends_on is not None:
+            for process in enumerate(self.config.depends_on):
+                if self.config.depends_on[process[0]].state not in RUNNING_STATES:
+                    self.config.depends_on[process[0]].spawn()
 
         options = self.config.options
         processname = as_string(self.config.name)

supervisor/supervisord.py

@@ -89,14 +89,20 @@ def run(self):
             g = Graph(len(self.options.process_group_configs))
             # replace depends_on string with actual process object
             for config in (self.options.process_group_configs):
-                # this can be of form group:process or simply process
-                try: 
-                    dependent_group, dependent_process=depends_on.split(":")
-                except:
-                    dependent_group=dependent_process=depends_on
                 if config.process_configs[0].depends_on is not None:
-                    g.addEdge(config.process_configs[0].name, dependent_process)
-                    config.process_configs[0].depends_on = self.process_groups[dependent_group].processes[dependent_process]
+                    processes=[]
+                    # split to get all processes in case there are multiple dependencies
+                    dependent_processes = (config.process_configs[0].depends_on).split()
+                    for process in dependent_processes:
+                        # this can be of form group:process or simply process
+                        try: 
+                            dependent_group, dependent_process=process.split(":")
+                        except:
+                            dependent_group=dependent_process=process
+                        g.addEdge(config.process_configs[0].name, dependent_process)
+                        print(f'adding edge {config.process_configs[0].name, dependent_process}')
+                        processes.append(self.process_groups[dependent_group].processes[dependent_process])
+                    config.process_configs[0].depends_on = processes
             # check for cyclical process dependencies
             if g.cyclic() == 1:
                 raise AttributeError('Process config contains dependeny cycle(s)! Check config files again!')