timeflux.core.scheduler


timeflux.core.schedule: run nodes

scheduler

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