Function _get_np_dtype has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

    def _get_np_dtype(dtype: str, bit_depth: int) -> "nt.DTypeLike":
        dtype = dtype.lower()
        num_bits = int(dtype[1:])
        if dtype[0] == "u":
            num_bytes = num_bits // 8

• Read up
  Read up

Function cbed_frame has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

def cbed_frame(
        fy=128, fx=128, zero=None, a=None, b=None, indices=None,
        radius=4, all_equal=False, margin=None):
    if zero is None:
        zero = (fy//2, fx//2)

• Read up
  Read up

Function data has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

    def data(self):
        """
        Get the buffer contents in shape that corresponds to the
        original dataset shape, using a lazy Dask array.

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

                        with tracer.start_as_current_span("WARMUP"):
                            import libertem.udf.base  # NOQA
                            import libertem.api  # NOQA
                            import libertem.preload  # NOQA
                            with env.enter():

Function allocate has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

    def allocate(self, lib=None):
        """
        Allocate a buffer as a dask array

        nav buffer chunking is made identical to the partition structure

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

                        if __threadpool_counter == 0:
                            # The limit is set upon calling ThreadpoolController.limit()
                            __threadpool_limiter = __threadpool_wrapper(n)
                        __threadpool_counter += 1

Function radial_bins has 10 arguments (exceeds 8 allowed). Consider refactoring.

Open

def radial_bins(centerX, centerY, imageSizeX, imageSizeY,

Avoid deeply nested control flow statements.

Open

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

Function get_contiguous_view_for_tile has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

    def get_contiguous_view_for_tile(self, partition, tile):
        '''
        Make a cached contiguous copy of the view for a single tile
        if necessary.

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

                    if found_first_tile:
                        break
                    p.set_corrections(corrections)

Avoid deeply nested control flow statements.

Open

                        with tracer.start_as_current_span("SHUTDOWN"):
                            queues.request.close()
                            queues.response.close(drain=False)
                            queues.message.close(drain=False)
                        break

Function _compute has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

    def _compute(self, *args, udfs=None, user_backends=None, traverse=True, **kwargs):
        """
        Acts as dask.compute(*args, **kwargs) but with knowledge
        of Libertem data structures and compute resources
        """

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

                    for index in repair_environments[i, :repair_counts[i]]:
                        acc += buffer[nav, index]
                    buffer[nav, p] = acc / repair_counts[i]

Function _mib_r24_px_to_bytes has 10 arguments (exceeds 8 allowed). Consider refactoring.

Open

def _mib_r24_px_to_bytes(

Avoid deeply nested control flow statements.

Open

                        if tile.dtype != read_dtype or tile.c_contiguous is False:
                            data = tile.data.astype(read_dtype)
                        else:
                            data = tile.data
                        self.preprocess(data, tile.tile_slice, corrections)

Function analysisReducer has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

export const analysisReducer = (state = initialAnalysisState, action: AllActions): AnalysisReducerState => {
    switch (action.type) {
        case analysisActions.ActionTypes.CREATED: {
            return insertById(state, action.payload.analysis.id, action.payload.analysis);
        }

• Read up
  Read up

Function _default_px_to_bytes has 10 arguments (exceeds 8 allowed). Consider refactoring.

Open

def _default_px_to_bytes(

Function _wrapup_udfs has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

    def _wrapup_udfs(
        self,
        partition: Partition
    ) -> None:
        for udf in self._udfs:

• Read up
  Read up

Function need_copy has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

    def need_copy(
        self, decoder, roi, native_dtype, read_dtype, tiling_scheme=None, fileset=None,
        sync_offset=0, corrections=None,
    ) -> bool:
        # checking conditions in which "straight mmap" is not possible

• Read up
  Read up

Function ClusterStatus has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

const ClusterStatus: React.FC<MergedProps> = ({ clusterConnection, channelStatus, type, localcore, cudas, address }) => {
    enum ColorType {
        blue = "blue",
        grey = "grey",
        orange = "orange",

• Read up
  Read up