Diff Coverage

Diff: origin/r1.0.0...HEAD, staged and unstaged changes

Source File Diff Coverage (%) Missing Lines
hyper_parallel/core/shard/_op_dispatch.py 100%  
hyper_parallel/core/shard/ops/parallel_expand.py 100%  
hyper_parallel/core/shard/ops/parallel_ms_flash_attention_score.py 50.0% 1045-1050,1052,1056-1057,1059-1060
hyper_parallel/core/shard/ops/parallel_norm.py 100%  
hyper_parallel/core/shard/ops/parallel_one_hot_ext.py 0.0% 58
hyper_parallel/core/shard/ops/parallel_ops.py 100%  
hyper_parallel/core/shard/ops/parallel_scaled_dot_product_attention.py 100%  
hyper_parallel/core/shard/ops/parallel_stack.py 100%  
hyper_parallel/core/shard/ops/parallel_ms_flash_attention_score.py
1041
1042
1043
1044
1045
1046
1047
1048
1049
1050
1051
1052
1053
1054
1055
1056
1057
1058
1059
1060
1061
1062
1063
        Returns:
            Tuple of (adjusted_sparse_mode, adjusted_pre_tokens, adjusted_next_tokens,
                      adjusted_actual_seq_qlen, adjusted_actual_seq_kvlen).
        """
        adjusted_sparse_mode = context.sparse_mode
        adjusted_pre_tokens = context.pre_tokens
        adjusted_next_tokens = context.next_tokens
        adjusted_actual_seq_qlen = context.actual_seq_qlen
        adjusted_actual_seq_kvlen = context.actual_seq_kvlen
        seq_split_num = context.seq_split_num

        if seq_split_num > 1 or context.lb_split_id is not None:
            dynamic_info = self._get_dynamic_shape_info(query, key, input_layout)
            is_dynamic = dynamic_info.get('is_dynamic', False)

            if context.lb_split_id is not None:
                if context.lb_split_num is None:
                    raise ValueError("lb_split_num must not be None when lb_split_id is set")
                split_id = context.lb_split_id
                seq_split_num = context.lb_split_num
            else:
                split_id = self._get_split_id(query_layout, input_layout)
            seq_dim_idx = self._get_seq_dim_idx(self._layout_dims.get(input_layout, {}))
hyper_parallel/core/shard/ops/parallel_one_hot_ext.py
54
55
56
57
58
59
60
61
62
        off_value_layout = off_value.layout if hasattr(off_value, '_layout') else None

        local_args = (indices_local, num_classes, on_value_local, off_value_local, axis)
        cache_values = [indices.layout, on_value_layout, off_value_layout, num_classes, axis]
        return local_args, {}, cache_values

    # pylint: disable=W0237
    def infer_layout(self, cache_values: list) -> Tuple[tuple, None]:
        """