Function _order_results has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

def _order_results(results_in: ResultWithID) -> ResultT:
    """
    Order the `results_in` generator by the result id, yielding ordered results.
    Requires indexes to be without gaps.
    """

• Read up
  Read up

Function read_tiles_with_roi has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

def read_tiles_with_roi(
    triple: CSRTriple,
    partition_slice: Slice,
    sync_offset: int,
    tiling_scheme: TilingScheme,

• Read up
  Read up

Function flatten_filter has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

def flatten_filter(excluded_pixels, repairs, repair_counts, sig_shape):
    '''
    Flatten excluded pixels and repair environments and filter for collisions

    Ravel indices to flattened signal dimension and

• Read up
  Read up

Function async_to_sync_generator has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

def async_to_sync_generator(agen, pool=None):
    span = trace.get_current_span()
    span_context = span.get_span_context()
    q = queue.Queue()
    t = AsyncGenToQueueThread(agen, q, span_context)

• Read up
  Read up

Function _start_pool has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

    def _start_pool(self) -> WorkerPool:
        with tracer.start_as_current_span("PipelinedExecutor.start_pool") as span:
            pool = WorkerPool(
                worker_fn=functools.partial(
                    pipelined_worker,

• Read up
  Read up

Function _get_dependencies has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

        def _get_dependencies(self, cvar):
            deps = [cvar]
            if hasattr(cvar, 'py_func'):
                # TODO: does the cache key need to depend on any other
                # attributes of the Dispatcher?

• Read up
  Read up

Function calc_coords has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

    def calc_coords(self, indices=None, drop_zero=False, frame_shape=None, r=0):
        '''
        Shorthand to calculate peak coordinates.

        Parameters

• Read up
  Read up

Function main has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

def main(kind, scheduler, local_directory, n_cpus, cudas,
         has_cupy, name, log_level, preload: tuple[str, ...]):
    from libertem.common.threading import set_num_threads_env
    with set_num_threads_env(1):
        from libertem.utils.devices import detect

• Read up
  Read up

Function _get_subslices has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

    def _get_subslices(self, tiling_scheme):
        """
        Generate partition subslices for the given tiling scheme for the different cases.
        """
        if tiling_scheme.intent == "partition":

• Read up
  Read up

Function __init__ has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

    def __init__(self, masks: MaskContainer, meta: UDFMeta, use_torch: bool):
        self.masks = masks
        self.meta = meta

        try:

• Read up
  Read up

Function adjustShapeWithBounds has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

export const adjustShapeWithBounds = (shape: string, shapeType: "nav"|"sig"): string => {
    const { minLength, maxLength } = getMinAndMaxShapeLength(shapeType);

    let adjustedShape = new Array<string>(minLength).fill("");

• Read up
  Read up

Function _init_udfs has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

    def _init_udfs(
        self,
        execution_plan: ExecutionPlan,
        partition: Partition,
        roi: Optional[np.ndarray],

• Read up
  Read up

Function GPUSelector has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

export const GPUSelector: React.FC<GPUSelectorProps> = ({
    config, name, value, setFieldValue,
}) => {
    const hasCupy = config.devices.has_cupy;
    const cudaIds = config.devices.cudas;

• Read up
  Read up

Function _get_datasets has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

def _get_datasets(path):
    datasets: list[HDF5ArrayDescriptor] = []

    try:
        timeout = int(os.environ.get('LIBERTEM_IO_HDF5_TIMEOUT_DEBUG', 3))

• Read up
  Read up

Function get_tiles has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

    def get_tiles(self, *args, **kwargs):
        if args and isinstance(args[0], TilingScheme):
            tiling_scheme = args[0]
            args = args[1:]
            intent = tiling_scheme.intent

• Read up
  Read up

Function run has 11 arguments (exceeds 8 allowed). Consider refactoring.

Open

def run(

Function _buffered_tilereader has 11 arguments (exceeds 8 allowed). Consider refactoring.

Open

    def _buffered_tilereader(outer_idx, buffers, sig_dims, tile_read_ranges,

Avoid deeply nested control flow statements.

Open

                        if __threadpool_counter == 0 and __threadpool_limiter is not None:
                            __threadpool_limiter.restore_original_limits()
                            __threadpool_limiter = None

Avoid deeply nested control flow statements.

Open

                    for t in p.get_tiles(tiling_scheme=tiling_scheme, roi=roi):
                        found_first_tile = True
                        break

Avoid deeply nested control flow statements.

Open

                    if found_first_tile:
                        break
                    p.set_corrections(corrections)