#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/catalog/services/udf_metadata_catalog_service.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 List

from sqlalchemy.orm import Session
from sqlalchemy.sql.expression import select

from evadb.catalog.models.udf_metadata_catalog import (
    UdfMetadataCatalog,
    UdfMetadataCatalogEntry,
)
from evadb.catalog.services.base_service import BaseService
from evadb.utils.errors import CatalogError
from evadb.utils.logging_manager import logger


class UdfMetadataCatalogService(BaseService):
    def __init__(self, db_session: Session):
        super().__init__(UdfMetadataCatalog, db_session)

    def insert_entries(self, entries: List[UdfMetadataCatalogEntry]):
        try:
            for entry in entries:
                metadata_obj = UdfMetadataCatalog(
                    key=entry.key, value=entry.value, udf_id=entry.udf_id
                )
                metadata_obj.save(self.session)
        except Exception as e:
            logger.exception(
                f"Failed to insert entry {entry} into udf metadata catalog with exception {str(e)}"
            )
            raise CatalogError(e)

    def get_entries_by_udf_id(self, udf_id: int) -> List[UdfMetadataCatalogEntry]:
        try:
            result = (
                self.session.execute(
                    select(self.model).filter(
                        self.model._udf_id == udf_id,
                    )
                )
                .scalars()
                .all()
            )
            return [obj.as_dataclass() for obj in result]
        except Exception as e:
            error = f"Getting metadata entries for UDF id {udf_id} raised {e}"
            logger.error(error)
            raise CatalogError(error)

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	from typing import List	×
16
17	from sqlalchemy.orm import Session	×
18	from sqlalchemy.sql.expression import select	×
19
20	from evadb.catalog.models.udf_metadata_catalog import (	×
21	UdfMetadataCatalog,
22	UdfMetadataCatalogEntry,
23	)
24	from evadb.catalog.services.base_service import BaseService	×
25	from evadb.utils.errors import CatalogError	×
26	from evadb.utils.logging_manager import logger	×
27
28
29	class UdfMetadataCatalogService(BaseService):	×
30	def __init__(self, db_session: Session):	×
31	super().__init__(UdfMetadataCatalog, db_session)	×
32
33	def insert_entries(self, entries: List[UdfMetadataCatalogEntry]):	×
34	try:	×
35	for entry in entries:	×
36	metadata_obj = UdfMetadataCatalog(	×
37	key=entry.key, value=entry.value, udf_id=entry.udf_id
38	)
39	metadata_obj.save(self.session)	×
40	except Exception as e:
41	logger.exception(
42	f"Failed to insert entry {entry} into udf metadata catalog with exception {str(e)}"
43	)
44	raise CatalogError(e)
45
46	def get_entries_by_udf_id(self, udf_id: int) -> List[UdfMetadataCatalogEntry]:	×
47	try:	×
48	result = (	×
49	self.session.execute(
50	select(self.model).filter(
51	self.model._udf_id == udf_id,
52	)
53	)
54	.scalars()
55	.all()
56	)
57	return [obj.as_dataclass() for obj in result]	×
58	except Exception as e:
59	error = f"Getting metadata entries for UDF id {udf_id} raised {e}"
60	logger.error(error)
61	raise CatalogError(error)

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