dask_jobqueue.slurm.SLURMRunner

dask_jobqueue.slurm.SLURMRunner

class dask_jobqueue.slurm.SLURMRunner(*args, scheduler_file='scheduler-{job_id}.json', **kwargs)
__init__(*args, scheduler_file='scheduler-{job_id}.json', **kwargs)

Methods

__init__(*args[, scheduler_file])

before_client_start()

before_scheduler_start()

before_worker_start()

close()

get_role()

get_scheduler_address()

get_worker_name()

on_scheduler_start(scheduler)

on_worker_start(worker)

set_scheduler_address(scheduler)

start_scheduler()

start_worker()

sync(func, *args[, asynchronous, ...])

Call func with args synchronously or asynchronously depending on the calling context

Attributes

asynchronous

Are we running in the event loop?

loop

previous

Runners API

next

How to debug