BioImageTools/dask_waitformanager

module

Retrieve dask cluster info from the JSON file created by the scheduler

dask

Module Information

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

Tools

dask

Dask is a flexible library for parallel computing in Python.

License: BSD 3-Clause License

Inputs

Name Type Description
meta map
cluster_work_dir path The cluster work directory where the scheduler will run

Outputs

Name Type Description
meta map
cluster_work_fullpath string Full path to the cluster work directory where the scheduler is running
cluster_address string Dask cluster scheduler's address
available_workers int Number of available workers - this is always 0 here

Quick Start

Include this module in your Nextflow pipeline:

include { DASK_WAITFORMANAGER } from 'https://github.com/BioImageTools/nextflow-modules/tree/main/modules/bits/dask/waitformanager'
View on GitHub Report Issue