BioImageTools/dask_waitforworkers

module

Check if a worker is running

dask

Module Information

Repository: https://github.com/BioImageTools/nextflow-modules/tree/main/modules/bits/dask/waitforworkers
Source: BioImageTools
Organization: BioImageTools
Authors: @cgoina , @krokicki

Dask is a flexible library for parallel computing in Python.

License: BSD 3-Clause License

Name	Type	Description
meta	map
scheduler_address	string	Scheduler's IP address
cluster_work_dir	path	The cluster work directory where the scheduler will run
total_workers	int	Total number of workers in the cluster
required_workers	int	Number of workers that should be available before the cluster is being used

Name	Type	Description
meta	map
scheduler_address	string	Scheduler's IP address
cluster_work_fullpath	string	Full path to the cluster work directory where the scheduler is running
available_workers	int	Number of workers that are ready
versions	string	Software versions file

Include this module in your Nextflow pipeline:

include { DASK_WAITFORWORKERS } from 'https://github.com/BioImageTools/nextflow-modules/tree/main/modules/bits/dask/waitforworkers'