timeflux.core.worker


timeflux.core.worker: spawn processes.

worker

class timeflux.core.worker.Worker(graph)[source]

Spawn a process and launch a scheduler.

run(self)[source]

Run the process

load(self)[source]