prologin.masternode.master module

class prologin.masternode.master.MasterNode(*args, config=None, **kwargs)

Bases: prologin.rpc.server.BaseRPCApp

REMOTE_METHODS = {'compilation_result': <function MasterNode.compilation_result>, 'heartbeat': <function MasterNode.heartbeat>, 'match_done': <function MasterNode.match_done>, 'status': <function MasterNode.status>, 'update_worker': <function MasterNode.update_worker>}

async compilation_result(worker, cid, user, ret, b64compiled, log)

async dbwatcher_task(name, fetcher)

async dispatch_tasks(queue_name, tasks)

find_worker_for(task)

async get_requested_compilations(status='new')

async get_requested_matches(status='new')

async heartbeat(worker, first)

async janitor_task()

async match_done(worker, mid, result, dumper_stdout, replay, server_stats, server_stdout, players_stdout)

async redispatch_worker(worker)

async register_worker(key, w)

async resubmit_timeout_tasks(worker)

run()

async status()

async update_worker(worker)