timeflux.core.scheduler

timeflux.core.schedule: run nodes

scheduler

class timeflux.core.scheduler.Scheduler(path, nodes, rate)[source]
run()[source]
next()[source]
terminate()[source]