removed usage of external worker process
This commit is contained in:
+10
-1
@@ -7,7 +7,8 @@ import os
|
|||||||
from configparser import ConfigParser
|
from configparser import ConfigParser
|
||||||
from pathlib import Path
|
from pathlib import Path
|
||||||
import socket
|
import socket
|
||||||
|
# from multiprocessing import Queue
|
||||||
|
# from worker import Worker
|
||||||
|
|
||||||
# load default values
|
# load default values
|
||||||
config = ConfigParser()
|
config = ConfigParser()
|
||||||
@@ -23,9 +24,17 @@ if __name__ == '__main__':
|
|||||||
listen_ip = os.getenv('LISTEN_IP', default=LISTEN_IP)
|
listen_ip = os.getenv('LISTEN_IP', default=LISTEN_IP)
|
||||||
listen_port = int(os.getenv('LISTEN_PORT', default=LISTEN_PORT))
|
listen_port = int(os.getenv('LISTEN_PORT', default=LISTEN_PORT))
|
||||||
own_ip = socket.gethostbyname(socket.gethostname())
|
own_ip = socket.gethostbyname(socket.gethostname())
|
||||||
|
# # setup work queue
|
||||||
|
# work_queue: Queue = Queue()
|
||||||
|
# # setup worker process
|
||||||
|
# worker = Worker(queue=work_queue)
|
||||||
|
# start server
|
||||||
logging.info(f'starting FastAPI server ({own_ip}:{listen_port})')
|
logging.info(f'starting FastAPI server ({own_ip}:{listen_port})')
|
||||||
|
# try:
|
||||||
uvicorn.run(
|
uvicorn.run(
|
||||||
app=app,
|
app=app,
|
||||||
host=listen_ip,
|
host=listen_ip,
|
||||||
port=listen_port
|
port=listen_port
|
||||||
)
|
)
|
||||||
|
# except KeyboardInterrupt:
|
||||||
|
# worker.stop()
|
||||||
|
|||||||
Reference in New Issue
Block a user