Multiprocessing

ondemand/service.py

@@ -14,6 +14,7 @@ from firebase_admin import db as fbdb
 from binascii import hexlify
 from base64 import b64decode
 from threading import Thread
+from multiprocessing import Process
 from argparse import ArgumentParser
 import logging as log
 import firebase_admin
@@ -40,6 +41,8 @@ MAX_SEGMENT_THREADS = 2
 QUEUE_SINGLE = 1
 QUEUE_THREAD = 2
 
+MultiAPI = Process # Se puede cambiar por Thread
+
 config = parse_config()
 queue = Queue()
 client = Client(config['device_id'],
@@ -119,7 +122,7 @@ def process_queue_with_threads():
                     station = item['station']
                     date = dateutil.parser.parse(item['date'])
 
-                    thread = Thread(target=process_segment,
+                    thread = MultiAPI(target=process_segment,
                         args=(item,),
                         kwargs={
                             'audios': [f for f in iterate_audios(date, station)]