nv_dfm_core.targets.local.JobRunner

class nv_dfm_core.targets.local.JobRunner(site, channels, yield_queue, inter_job_queue, logger)

The JobRunner is a worker process that represents the logic running on a dfm site. It receives tasks from an input queue, instantiates a target-specific router (passing it all the input queues for the other sites so it can route between them), and creates and starts the controller.

Parameters:

• site (str)

• channels (dict[str, Queue])

• yield_queue (Queue)

• inter_job_queue (Queue)

• logger (Logger)

run()

The main loop of the worker process.