DistAPIBase

class atqo.DistAPIBase

Bases: ABC

Attributes Summary

exception

Methods Summary

get_future(actor, next_task)
get_running_actor(actor_creator)
join()	wait on all running tasks
kill(actor)
parse_exception(e)

Attributes Documentation

exception

Methods Documentation

static get_future(actor: ActorBase, next_task: SchedulerTask) → Future

static get_running_actor(actor_creator) → ActorBase

join()

wait on all running tasks

static kill(actor: ActorBase)

static parse_exception(e)