local module

class mavis.schedule.local.LocalJob(args, func, rank=None, response=None, *pos, **kwargs)[source]

Bases: mavis.schedule.job.Job

Parameters:
  • args (list) – A list of arguments to passed to the function given
  • func (callable) – the function to be run
  • rank (int) – rank of the job within the pool
  • response (Future) – the result from the subprocess
check_complete()[source]

check that the complete stamp associated with this job exists

flatten()[source]
class mavis.schedule.local.LocalScheduler(*pos, **kwargs)[source]

Bases: mavis.schedule.scheduler.Scheduler

Scheduler class for dealing with running mavis locally

NAME = 'LOCAL'

the type of scheduler

Type:SCHEDULER
close()[source]
submit(job)[source]

Add a job to the pool

Parameters:job (LocalJob) – the job to be submitted
update_info(job)[source]
Parameters:job (LocalJob) – the job to check and update the status for
wait()[source]

wait for everything in the current pool to finish

mavis.schedule.local.write_stamp_callback(response)[source]