gluonts.nursery.glide.parallel module#

class gluonts.nursery.glide.parallel.ParApply(fn, emitter, batch_size=1, queue_size=50, encode=<function identity>, decode=<function identity>)[source]#: Bases: object

class gluonts.nursery.glide.parallel.ParApplyIterator(procs, queue, decode)[source]#

Bases: object

join()[source]#

kill()[source]#

start()[source]#

terminate()[source]#

gluonts.nursery.glide.parallel.map_to_queue(fn, emitter, queue, encode, batch_size)[source]#

class gluonts.nursery.glide.parallel.sentinel[source]#: Bases: object