working release

Author: lp1bp

.gitignore

@@ -0,0 +1,3 @@
+.python_manager.log
+__pycache__
+*/__pycache__

manager.py

@@ -1,14 +1,30 @@
 #!/bin/python
 import logging as log
+from importlib import import_module
+import services
+import config
+from modules.worker import Worker
 
 LOG_FILENAME = 'python_manager.log'
+dynamic_imports = []
+worker = Worker()
+
+class Service():
+  def __init__(self, name):
+    self.name = name
 
 def __init__():
+  global dynamic_imports
   log.basicConfig(filename=LOG_FILENAME,level=log.DEBUG)
+  for service in config.run.keys():
+    dynamic_imports.append(import_module('services.%s' %service))    
 
 def	main():
   __init__()
-  log.warning("lol")
+  for service_name in config.run.keys():
+    worker.add(Service(service_name))
+  worker.start()
+  log.info('All tasks done. Stopping')
   return 0
 
 if __name__ == '__main__':

modules/worker.py

@@ -0,0 +1,21 @@
+from threading import Thread
+import services
+
+class Worker():
+    def __init__(self):
+        self.threads = []
+        self.services = []
+        
+    def run_service(self, service):
+        eval("services.%s.main()" %service.name)
+            
+    def start(self):
+        for service in self.services:
+            t = Thread(target=self.run_service, args=[service])
+            self.threads.append(t)
+            t.start()
+
+    def add(self, service):
+        self.services.append(service)
+
+      

services/hello_world.py

@@ -0,0 +1,8 @@
+#!/bin/python
+
+def main(args=None):
+    print("hello world")
+    return 0
+
+if __name__ == "__main__":
+    main()