dacapo.blockwise.blockwise_task
Classes
A task to run a blockwise worker function. This task is used to run a |
Module Contents
- class dacapo.blockwise.blockwise_task.DaCapoBlockwiseTask(worker_file: str | upath.UPath, total_roi: daisy.Roi, read_roi: daisy.Roi, write_roi: daisy.Roi, num_workers: int = 16, max_retries: int = 2, timeout=None, upstream_tasks=None, *args, **kwargs)
A task to run a blockwise worker function. This task is used to run a blockwise worker function on a given ROI.
- worker_file
The path to the worker file.
- Type:
str | Path
- total_roi
The ROI to process.
- Type:
Roi
- read_roi
The ROI to read from for a block.
- Type:
Roi
- write_roi
The ROI to write to for a block.
- Type:
Roi
- num_workers
The number of workers to use.
- Type:
int
- max_retries
The maximum number of times a task will be retried if failed (either due to failed post check or application crashes or network failure)
- Type:
int
- timeout
The timeout for the task.
- upstream_tasks
The upstream tasks.
- \*args
Additional positional arguments to pass to
worker_function.
- \*\*kwargs
Additional keyword arguments to pass to
worker_function.
- __init__()
Initialize the task.
- worker_name
- worker
- timestamp
- task_id
- process_function
- read_write_conflict
- fit
- kwargs