cellmap_flow.blockwise.blockwise_processor

Attributes

Classes

CellMapFlowBlockwiseProcessor

Functions

`check_block`(→ bool)
`spawn_worker`(name, yaml_config, charge_group, queue[, ...])

Module Contents

cellmap_flow.blockwise.blockwise_processor.logger

class cellmap_flow.blockwise.blockwise_processor.CellMapFlowBlockwiseProcessor(yaml_config: str, create=False)

config

yaml_config

input_path

charge_group

queue

output_path

workers

output_channels_is_dict = False

cpu_workers

tmp_dir

models = []

model_mode_str

process_only

cross_channels_mode

model_config

block_shape

input_voxel_size

output_voxel_size

channels

task_name

dtype

inferencers

inferencer

idi_raw

output_arrays = []

bounding_boxes

separate_zarrs

process_fn(block)

client()

run()

cellmap_flow.blockwise.blockwise_processor.check_block(tmp_dir, block: daisy.Block) → bool

cellmap_flow.blockwise.blockwise_processor.spawn_worker(name, yaml_config, charge_group, queue, ncpu=12)