timeflux.core.worker


timeflux.core.worker: spawn processes.

worker

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

Spawn a process and launch a scheduler.

run()[source]

Run the process

load()[source]