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)¶
方法
__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, ...])根据调用上下文，同步或异步调用 func 与 args
属性
asynchronous我们是否正在事件循环中运行？
loop