Обновление данных в процессе-потребителе

from tornado import escape
from tornado.web import RequestHandler
from tornado.httpserver import HTTPServer
from tornado.ioloop import IOLoop
from tornado.web import Application
from db_service.db import run_db, VideoTag
import schedule
import datetime
import multiprocessing as mp
 
session = run_db()
q = mp.Queue(1)
info = 'Old data'
 
 
class VideoHandler(RequestHandler):
 
    def get(self):
        # data = escape.json_decode(self.request.body)
        if not q.empty():
            global info
            info = 'Actual data: {}\n'.format(q.get())
 
        self.write(info)
 
    def post(self):
        pass
 
 
def load_data_service():
    def load_data():
        q.put(datetime.datetime.now())
 
    schedule.every(10).seconds.do(load_data)
 
    while True:
        schedule.run_pending()
 
 
def video_service():
    app = Application([
        ('/video', VideoHandler),
    ])
    port, address = 8081, 'localhost'
    http_server = HTTPServer(app)
    http_server.listen(port, address=address)
    print('Listening on http://{}:{}'.format(address, port))
    IOLoop.current().start()
 
 
if __name__ == '__main__':
 
    p1 = mp.Process(target=video_service, args=())
    p1.start()
 
    p2 = mp.Process(target=load_data_service, args=())
    p2.start()
 
    p1.join()
    p2.join()