#758

Committed 04 Sep 2023 08:37PM UTC coverage: 0.0% (-78.3%) from 78.333%

Build # #758

Build Type

push

circle-ci

Committed by

hershd23

Commit Message

Increased underline length in at line 75 in text_summarization.rst
	modified:   docs/source/benchmarks/text_summarization.rst

Run Details

0 of 11303 relevant lines covered (0.0%)

0.0 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/evadb/plan_nodes/exchange_plan.py

# coding=utf-8
# Copyright 2018-2023 EvaDB
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

from typing import Any, Dict, List

from evadb.plan_nodes.abstract_plan import AbstractPlan
from evadb.plan_nodes.types import PlanOprType


class ExchangePlan(AbstractPlan):
    """
    This plan is used for storing information required for union operations.

    Arguments:
        all: Bool
            UNION (deduplication) vs UNION ALL (non-deduplication)
    """

    def __init__(
        self,
        inner_plan: AbstractPlan,
        parallelism: int = 1,
        ray_pull_env_conf_dict: Dict[str, Any] = {},
        ray_parallel_env_conf_dict: List[Dict[str, Any]] = [{}],
    ):
        self.inner_plan = inner_plan
        self.parallelism = parallelism
        # Environment variables to configure in the remote process. The problem of Ray remote function
        # is that we cannot control which GPU to spawn the job. Second, Ray does not offer anything
        # extra when specify GPU job. Just by giving environment variables like CUDA_VISIBLE_DEVICES,
        # our system can have more control over the behavior of Ray.
        self.ray_parallel_env_conf_dict = ray_parallel_env_conf_dict
        self.ray_pull_env_conf_dict = ray_pull_env_conf_dict
        super().__init__(PlanOprType.EXCHANGE)

    def __str__(self) -> str:
        return "ExchangePlan"

    def __hash__(self) -> int:
        return hash(
            (
                super().__hash__(),
                self.inner_plan,
                self.parallelism,
            )
        )

1	# coding=utf-8
2	# Copyright 2018-2023 EvaDB
3	#
4	# Licensed under the Apache License, Version 2.0 (the "License");
5	# you may not use this file except in compliance with the License.
6	# You may obtain a copy of the License at
7	#
8	# http://www.apache.org/licenses/LICENSE-2.0
9	#
10	# Unless required by applicable law or agreed to in writing, software
11	# distributed under the License is distributed on an "AS IS" BASIS,
12	# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13	# See the License for the specific language governing permissions and
14	# limitations under the License.
15
16	from typing import Any, Dict, List	×
17
18	from evadb.plan_nodes.abstract_plan import AbstractPlan	×
19	from evadb.plan_nodes.types import PlanOprType	×
20
21
22	class ExchangePlan(AbstractPlan):	×
23	"""
24	This plan is used for storing information required for union operations.
25
26	Arguments:
27	all: Bool
28	UNION (deduplication) vs UNION ALL (non-deduplication)
29	"""
30
31	def __init__(	×
32	self,
33	inner_plan: AbstractPlan,
34	parallelism: int = 1,
35	ray_pull_env_conf_dict: Dict[str, Any] = {},
36	ray_parallel_env_conf_dict: List[Dict[str, Any]] = [{}],
37	):
38	self.inner_plan = inner_plan	×
39	self.parallelism = parallelism	×
40	# Environment variables to configure in the remote process. The problem of Ray remote function
41	# is that we cannot control which GPU to spawn the job. Second, Ray does not offer anything
42	# extra when specify GPU job. Just by giving environment variables like CUDA_VISIBLE_DEVICES,
43	# our system can have more control over the behavior of Ray.
44	self.ray_parallel_env_conf_dict = ray_parallel_env_conf_dict	×
45	self.ray_pull_env_conf_dict = ray_pull_env_conf_dict	×
46	super().__init__(PlanOprType.EXCHANGE)	×
47
48	def __str__(self) -> str:	×
49	return "ExchangePlan"	×
50
51	def __hash__(self) -> int:	×
52	return hash(	×
53	(
54	super().__hash__(),
55	self.inner_plan,
56	self.parallelism,
57	)
58	)

georgia-tech-db / eva / #758

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous