for p in processes_to_check:
if not _contains_process(processes_running, p):
log.error("Process %s not running!" % p)
return False
# Check if process is running properly (listening to kafka bus)
for p in processes_to_check:
if not _contains_process(processes_running, p):
log.error("Process %s not running!" % p)
return False
# Check if process is running properly (listening to kafka bus)