zaku.server
Task Server#

class zaku.server.Redis[source]#

Bases: ParamsProto

Redis Configuration for the TaskServer class.

# Put this into an .env file
REDIS_HOST=localhost
REDIS_PORT=6379
REDIS_PASSWORD=xxxxxxxxxxxxxxxxxxx
REDIS_DB=0

CLI Options:

--redis.host      :str 'localhost'
--redis.port      :int 6379
--redis.password  :any None
--redis.db        :any 0
host = 'localhost'#
port = 6379#
password = None#
db = 0#

The logical redis database, from 0 - 15.

class zaku.server.TaskServer[source]#

Bases: ParamsProto, Server

TaskServer

This is the server that maintains the Task Queue.

Usage

app = TaskServer()
app.run()

CLI Options

python -m zaku.server --help

-h, --help          show this help message and exit
--prefix          :str 'Zaku-task-queues'
--queue-len       :int 100
--port            :int 9000
--free-port       :bool True
--static-root     :str '.'
--cors            :str 'https://vuer.ai,https://dash.ml,http://lo...
--cert            :str None the path to the SSL certificate
--key             :str None the path to the SSL key
--ca-cert         :str None the trusted root CA certificates
--REQUEST-MAX-SIZE  :int 100000000 the maximum packet size
prefix = 'Zaku-task-queues'#
queue_len = 100#
port: int = 9000#
free_port = True#
static_root = '.'#
cors: str = 'https://vuer.ai,https://dash.ml,http://localhost:8000,http://127.0.0.1:8000,*'#

Enable CORS

cert: str = None#

the path to the SSL certificate

key: str = None#

the path to the SSL key

ca_cert: str = None#

the trusted root CA certificates

REQUEST_MAX_SIZE = 100000000#
WEBSOCKET_MAX_SIZE = 268435456#
host: str = 'localhost'#
zaku.server.entry_point()[source]#