diff --git a/.github/workflows/pr-title-checker.yml b/.github/workflows/pr-title-checker.yml index 827f619b..ae7befd4 100644 --- a/.github/workflows/pr-title-checker.yml +++ b/.github/workflows/pr-title-checker.yml @@ -12,6 +12,7 @@ jobs: name: Validate PR title runs-on: ubuntu-latest steps: + # https://www.conventionalcommits.org/en/v1.0.0/#summary - uses: amannn/action-semantic-pull-request@v5 env: GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }} diff --git a/README.md b/README.md index 45315221..aaa16a06 100644 --- a/README.md +++ b/README.md @@ -4,7 +4,7 @@ [![License](https://img.shields.io/badge/License-Apache%202.0-blue.svg)](./LICENSE) -OpenSPG is a knowledge graph engine developed by Ant Group in collaboration with OpenKG, based on the SPG (Semantic-enhanced Programmable Graph) framework, which is a summary of Ant Group's years of experience in constructing and applying diverse domain knowledge graphs in the financial scenarios. +[OpenSPG](https://spg.openkg.cn/en-US) is a knowledge graph engine developed by Ant Group in collaboration with OpenKG, based on the SPG (Semantic-enhanced Programmable Graph) framework, which is a summary of Ant Group's years of experience in constructing and applying diverse domain knowledge graphs in the financial scenarios. ![OpenSPG Architecture](https://mdn.alipayobjects.com/huamei_xgb3qj/afts/img/A*DmdvRKo5pyYAAAAAAAAAAAAADtmcAQ/original) @@ -13,7 +13,7 @@ OpenSPG is a knowledge graph engine developed by Ant Group in collaboration with SPG (Semantic-enhanced Programmable Graph): semantic-enhanced programmable framework is a set of semantic representation framework based on property graph precipitated by Ant Knowledge Graph platform after years of supporting business in the financial field. It creatively integrates LPG structural and RDF semantic, which overcomes the problem that RDF/OWL semantic complexity cannot be industrially landed, and fully inherits the advantages of LPG structural simplicity and compatibility with big data system. The framework defines and represents knowledge semantics from three aspects. First, SPG explicitly defines the formal representation and programmable framework of "knowledge", so that it can be defined, programmed, understood and processed by machines. Secondly, SPG achieves compatibility and progressive advancement between knowledge levels, supporting the construction of knowledge graphs and the continuous iterative evolution of incomplete data states in industrial-level scenarios. Finally, SPG serves as an effective bridge between big data and AI technology systems, facilitating the efficient transformation of massive data into knowledge-based insights. By doing so, it enhances the value and application potential of the data. With the SPG framework, we can construct and manage graph data more efficiently, and at the same time, we can better support business requirements and application scenarios. Since SPG framework has good scalability and flexibility, new business scenarios can quickly build their domain models and solutions by extending the domain knowledge model and developing new operators. -For a detailed introduction to SPG, please refer to **the [《SPG White Paper》](https://spg.openkg.cn/ "SPG White Paper") jointly released by Ant Group and OpenKG**. +For a detailed introduction to SPG, please refer to **the [《SPG White Paper》](https://spg.openkg.cn/en-US "SPG White Paper") jointly released by Ant Group and OpenKG**. # OpenSPG diff --git a/README_cn.md b/README_cn.md index 5b9a5610..e82091f5 100644 --- a/README_cn.md +++ b/README_cn.md @@ -2,7 +2,7 @@ [![License](https://img.shields.io/badge/License-Apache%202.0-blue.svg)](./LICENSE) -OpenSPG 是蚂蚁集团结合多年金融领域多元场景知识图谱构建与应用业务经验的总结，并与OpenKG联合推出的基于SPG(Semantic-enhanced Programmable Graph)框架研发的知识图谱引擎。 +(OpenSPG)[https://spg.openkg.cn] 是蚂蚁集团结合多年金融领域多元场景知识图谱构建与应用业务经验的总结，并与OpenKG联合推出的基于SPG(Semantic-enhanced Programmable Graph)框架研发的知识图谱引擎。 ![OpenSPG Architecture](https://mdn.alipayobjects.com/huamei_xgb3qj/afts/img/A*YYSpQoItezMAAAAAAAAAAAAADtmcAQ/original) diff --git a/builder/core/pom.xml b/builder/core/pom.xml index d8e9ec17..6171fabf 100644 --- a/builder/core/pom.xml +++ b/builder/core/pom.xml @@ -16,7 +16,7 @@ 4.0.0 com.antgroup.openspg.builder - openspg-builder-parent + builder-parent 0.0.1-SNAPSHOT ../pom.xml @@ -28,23 +28,23 @@ api-http-client - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-interface-graph-store - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-impl-graph-store-tugraph - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-interface-table-store - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-interface-search-engine - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-impl-search-engine-elasticsearch diff --git a/builder/model/pom.xml b/builder/model/pom.xml index 48154c7b..2826b9c2 100644 --- a/builder/model/pom.xml +++ b/builder/model/pom.xml @@ -16,7 +16,7 @@ 4.0.0 com.antgroup.openspg.builder - openspg-builder-parent + builder-parent 0.0.1-SNAPSHOT ../pom.xml diff --git a/builder/pom.xml b/builder/pom.xml index 8e765e18..936a83ea 100644 --- a/builder/pom.xml +++ b/builder/pom.xml @@ -23,7 +23,7 @@ com.antgroup.openspg.builder - openspg-builder-parent + builder-parent 0.0.1-SNAPSHOT pom diff --git a/builder/runner/local/pom.xml b/builder/runner/local/pom.xml index 887d31be..7ab1e9bd 100644 --- a/builder/runner/local/pom.xml +++ b/builder/runner/local/pom.xml @@ -1,10 +1,10 @@ + xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 4.0.0 com.antgroup.openspg.builder - openspg-builder-parent + builder-parent 0.0.1-SNAPSHOT ../../pom.xml diff --git a/cloudext/impl/graph-store/tugraph/pom.xml b/cloudext/impl/graph-store/tugraph/pom.xml index 8e557b6b..7197cd76 100644 --- a/cloudext/impl/graph-store/tugraph/pom.xml +++ b/cloudext/impl/graph-store/tugraph/pom.xml @@ -15,17 +15,17 @@ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 4.0.0 - com.antgroup.openspg - openspg-parent + com.antgroup.openspg.cloudext + cloudext-parent 0.0.1-SNAPSHOT - ../../../../pom.xml + ../../../pom.xml cloudext-impl-graph-store-tugraph - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-interface-graph-store diff --git a/cloudext/impl/object-store/local/pom.xml b/cloudext/impl/object-store/local/pom.xml index 901c30a2..a20049d3 100644 --- a/cloudext/impl/object-store/local/pom.xml +++ b/cloudext/impl/object-store/local/pom.xml @@ -15,17 +15,17 @@ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 4.0.0 - com.antgroup.openspg - openspg-parent + com.antgroup.openspg.cloudext + cloudext-parent 0.0.1-SNAPSHOT - ../../../../pom.xml + ../../../pom.xml cloudext-impl-object-store-local - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-interface-object-store diff --git a/cloudext/impl/search-engine/elasticsearch/pom.xml b/cloudext/impl/search-engine/elasticsearch/pom.xml index 3d311fce..44413040 100644 --- a/cloudext/impl/search-engine/elasticsearch/pom.xml +++ b/cloudext/impl/search-engine/elasticsearch/pom.xml @@ -15,17 +15,17 @@ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 4.0.0 - com.antgroup.openspg - openspg-parent + com.antgroup.openspg.cloudext + cloudext-parent 0.0.1-SNAPSHOT - ../../../../pom.xml + ../../../pom.xml cloudext-impl-search-engine-elasticsearch - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-interface-search-engine diff --git a/cloudext/impl/table-store/local/pom.xml b/cloudext/impl/table-store/local/pom.xml index 51e9d5d0..88b3a7dd 100644 --- a/cloudext/impl/table-store/local/pom.xml +++ b/cloudext/impl/table-store/local/pom.xml @@ -15,17 +15,17 @@ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 4.0.0 - com.antgroup.openspg - openspg-parent + com.antgroup.openspg.cloudext + cloudext-parent 0.0.1-SNAPSHOT - ../../../../pom.xml + ../../../pom.xml cloudext-impl-table-store-local - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-interface-table-store diff --git a/cloudext/interface/graph-store/pom.xml b/cloudext/interface/graph-store/pom.xml index 881fa286..fb00db04 100644 --- a/cloudext/interface/graph-store/pom.xml +++ b/cloudext/interface/graph-store/pom.xml @@ -15,10 +15,10 @@ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 4.0.0 - com.antgroup.openspg - openspg-parent + com.antgroup.openspg.cloudext + cloudext-parent 0.0.1-SNAPSHOT - ../../../pom.xml + ../../pom.xml cloudext-interface-graph-store diff --git a/cloudext/interface/object-store/pom.xml b/cloudext/interface/object-store/pom.xml index 1f828bcf..d9525030 100644 --- a/cloudext/interface/object-store/pom.xml +++ b/cloudext/interface/object-store/pom.xml @@ -15,10 +15,10 @@ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 4.0.0 - com.antgroup.openspg - openspg-parent + com.antgroup.openspg.cloudext + cloudext-parent 0.0.1-SNAPSHOT - ../../../pom.xml + ../../pom.xml cloudext-interface-object-store diff --git a/cloudext/interface/search-engine/pom.xml b/cloudext/interface/search-engine/pom.xml index d8c12525..ce966377 100644 --- a/cloudext/interface/search-engine/pom.xml +++ b/cloudext/interface/search-engine/pom.xml @@ -15,10 +15,10 @@ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 4.0.0 - com.antgroup.openspg - openspg-parent + com.antgroup.openspg.cloudext + cloudext-parent 0.0.1-SNAPSHOT - ../../../pom.xml + ../../pom.xml cloudext-interface-search-engine diff --git a/cloudext/interface/table-store/pom.xml b/cloudext/interface/table-store/pom.xml index d08c73cf..7246377e 100644 --- a/cloudext/interface/table-store/pom.xml +++ b/cloudext/interface/table-store/pom.xml @@ -15,10 +15,10 @@ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 4.0.0 - com.antgroup.openspg - openspg-parent + com.antgroup.openspg.cloudext + cloudext-parent 0.0.1-SNAPSHOT - ../../../pom.xml + ../../pom.xml cloudext-interface-table-store diff --git a/cloudext/pom.xml b/cloudext/pom.xml new file mode 100644 index 00000000..9923c6a0 --- /dev/null +++ b/cloudext/pom.xml @@ -0,0 +1,53 @@ + + + + 4.0.0 + + + com.antgroup.openspg + openspg-parent + 0.0.1-SNAPSHOT + ../pom.xml + + + com.antgroup.openspg.cloudext + cloudext-parent + 0.0.1-SNAPSHOT + pom + + + Apache 2.0 License + http://www.apache.org/licenses/LICENSE-2.0.html + repo + + + + + interface/graph-store + interface/object-store + interface/table-store + interface/search-engine + impl/graph-store/tugraph + impl/object-store/local + impl/table-store/local + impl/search-engine/elasticsearch + + + + + + + + diff --git a/pom.xml b/pom.xml index a35a64cd..4d855673 100644 --- a/pom.xml +++ b/pom.xml @@ -30,17 +30,9 @@ common/util server - builder reasoner - cloudext/interface/graph-store - cloudext/interface/object-store - cloudext/interface/table-store - cloudext/interface/search-engine - cloudext/impl/graph-store/tugraph - cloudext/impl/object-store/local - cloudext/impl/table-store/local - cloudext/impl/search-engine/elasticsearch - + builder + cloudext @@ -96,42 +88,42 @@ ${project.version} - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-interface-graph-store ${project.version} - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-interface-search-engine ${project.version} - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-interface-object-store ${project.version} - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-interface-table-store ${project.version} - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-impl-graph-store-tugraph ${project.version} - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-impl-object-store-local ${project.version} - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-impl-table-store-local ${project.version} - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-impl-search-engine-elasticsearch ${project.version} diff --git a/python/knext/api/client.py b/python/knext/api/client.py index 53137d57..9a541a1a 100644 --- a/python/knext/api/client.py +++ b/python/knext/api/client.py @@ -1,4 +1,3 @@ - from knext.client.builder import BuilderClient from knext.client.schema import SchemaClient from knext.client.reasoner import ReasonerClient @@ -10,5 +9,5 @@ __all__ = [ "SchemaClient", "ReasonerClient", "OperatorClient", - "SearchClient" + "SearchClient", ] diff --git a/python/knext/api/component.py b/python/knext/api/component.py index 1c3a22d7..4cc89f8e 100644 --- a/python/knext/api/component.py +++ b/python/knext/api/component.py @@ -1,4 +1,3 @@ - from knext.component.builder import UserDefinedExtractor, LLMBasedExtractor from knext.component.builder import SPGTypeMapping, RelationMapping from knext.component.builder import CsvSourceReader @@ -13,5 +12,5 @@ __all__ = [ "SPGTypeMapping", "RelationMapping", "KGSinkWriter", - "Component" + "Component", ] diff --git a/python/knext/chain/base.py b/python/knext/chain/base.py index 9f13a2f3..6d5b4a5e 100644 --- a/python/knext/chain/base.py +++ b/python/knext/chain/base.py @@ -17,14 +17,18 @@ class Chain(Runnable, RESTable): def to_rest(self): pass - def __rshift__(self, other: Union[ - Type['Chain'], - List[Type['Chain']], - Type['Component'], - List[Type['Component']], - None - ]): + def __rshift__( + self, + other: Union[ + Type["Chain"], + List[Type["Chain"]], + Type["Component"], + List[Type["Component"]], + None, + ], + ): from knext.component.base import Component + if not other: return self if not isinstance(other, list): @@ -34,7 +38,11 @@ class Chain(Runnable, RESTable): if not o: dag_list.append(o.dag) if isinstance(o, Component): - end_nodes = [node for node, out_degree in self.dag.out_degree() if out_degree == 0 or node.last] + end_nodes = [ + node + for node, out_degree in self.dag.out_degree() + if out_degree == 0 or node.last + ] dag = nx.DiGraph(self.dag) if len(end_nodes) > 0: for end_node in end_nodes: @@ -43,8 +51,14 @@ class Chain(Runnable, RESTable): dag_list.append(dag) elif isinstance(o, Chain): combined_dag = nx.compose(self.dag, o.dag) - end_nodes = [node for node, out_degree in self.dag.out_degree() if out_degree == 0 or node.last] - start_nodes = [node for node, in_degree in o.dag.in_degree() if in_degree == 0] + end_nodes = [ + node + for node, out_degree in self.dag.out_degree() + if out_degree == 0 or node.last + ] + start_nodes = [ + node for node, in_degree in o.dag.in_degree() if in_degree == 0 + ] if len(end_nodes) > 0 and len(start_nodes) > 0: for end_node in end_nodes: diff --git a/python/knext/chain/builder_chain.py b/python/knext/chain/builder_chain.py index 03fb9c15..65ab2f46 100644 --- a/python/knext/chain/builder_chain.py +++ b/python/knext/chain/builder_chain.py @@ -12,7 +12,10 @@ class BuilderChain(RESTable, Chain): source: SourceReader - process: Union[SPGExtractor, Mapping, ] + process: Union[ + SPGExtractor, + Mapping, + ] sink: SinkWriter diff --git a/python/knext/client/base.py b/python/knext/client/base.py index d4faf968..281f0e9f 100644 --- a/python/knext/client/base.py +++ b/python/knext/client/base.py @@ -2,4 +2,4 @@ from abc import ABC class Client(ABC): - pass \ No newline at end of file + pass diff --git a/python/knext/common/restable.py b/python/knext/common/restable.py index b6be904e..86f6ad20 100644 --- a/python/knext/common/restable.py +++ b/python/knext/common/restable.py @@ -5,13 +5,12 @@ from knext import rest class RESTable(ABC): - @property - def upstream_types(self) -> Type['RESTable']: + def upstream_types(self) -> Type["RESTable"]: raise NotImplementedError("To be implemented in subclass") @property - def downstream_types(self) -> Type['RESTable']: + def downstream_types(self) -> Type["RESTable"]: raise NotImplementedError("To be implemented in subclass") def to_rest(self) -> rest.Node: diff --git a/python/knext/common/schema_helper.py b/python/knext/common/schema_helper.py index 92433ba1..ea0a800a 100644 --- a/python/knext/common/schema_helper.py +++ b/python/knext/common/schema_helper.py @@ -10,13 +10,10 @@ class SchemaHelper(ABC): class SPGTypeHelper(SchemaHelper): - def __init__(self, type_name: str): super().__init__(type_name) class PropertyHelper(SchemaHelper): - def __init__(self, type_name: str): super().__init__(type_name) - diff --git a/python/knext/component/base.py b/python/knext/component/base.py index 3268c02d..cc0a81c5 100644 --- a/python/knext/component/base.py +++ b/python/knext/component/base.py @@ -54,14 +54,18 @@ class Component(Runnable, RESTable, ABC): def __eq__(self, other): return hash(self) == hash(other) - def __rshift__(self, other: Union[ - Type['Chain'], - List[Type['Chain']], - Type['Component'], - List[Type['Component']], - None - ]): + def __rshift__( + self, + other: Union[ + Type["Chain"], + List[Type["Chain"]], + Type["Component"], + List[Type["Component"]], + None, + ], + ): from knext.chain.base import Chain + if not other: return self if not isinstance(other, list): @@ -83,8 +87,14 @@ class Component(Runnable, RESTable, ABC): elif isinstance(o, Chain): dag = nx.DiGraph() dag.add_node(self) - end_nodes = [node for node, out_degree in dag.out_degree() if out_degree == 0 or node.last] - start_nodes = [node for node, in_degree in o.dag.in_degree() if in_degree == 0] + end_nodes = [ + node + for node, out_degree in dag.out_degree() + if out_degree == 0 or node.last + ] + start_nodes = [ + node for node, in_degree in o.dag.in_degree() if in_degree == 0 + ] if len(end_nodes) > 0 and len(start_nodes) > 0: for end_node in end_nodes: diff --git a/python/knext/component/builder/__init__.py b/python/knext/component/builder/__init__.py index 4bcc4d6d..b48a341a 100644 --- a/python/knext/component/builder/__init__.py +++ b/python/knext/component/builder/__init__.py @@ -1,5 +1,8 @@ - -from knext.component.builder.extractor import UserDefinedExtractor, LLMBasedExtractor, SPGExtractor +from knext.component.builder.extractor import ( + UserDefinedExtractor, + LLMBasedExtractor, + SPGExtractor, +) from knext.component.builder.mapping import SPGTypeMapping, RelationMapping, Mapping from knext.component.builder.source_reader import CsvSourceReader, SourceReader from knext.component.builder.sink_writer import KGSinkWriter, SinkWriter diff --git a/python/knext/component/builder/base.py b/python/knext/component/builder/base.py index 92aef247..05ecb9cf 100644 --- a/python/knext/component/builder/base.py +++ b/python/knext/component/builder/base.py @@ -14,7 +14,6 @@ class ComponentLabelEnum(str, Enum): class BuilderComponent(Component, ABC): - @property def type(self): return ComponentTypeEnum.Builder @@ -29,7 +28,6 @@ class BuilderComponent(Component, ABC): class SourceReader(BuilderComponent, ABC): - @property def upstream_types(self): return None @@ -44,7 +42,6 @@ class SourceReader(BuilderComponent, ABC): class SPGExtractor(BuilderComponent, ABC): - @property def upstream_types(self): return Union[SourceReader, SPGExtractor] @@ -59,7 +56,6 @@ class SPGExtractor(BuilderComponent, ABC): class Mapping(BuilderComponent, ABC): - @property def upstream_types(self): return Union[SourceReader, SPGExtractor] @@ -74,7 +70,6 @@ class Mapping(BuilderComponent, ABC): class SinkWriter(BuilderComponent, ABC): - @property def upstream_types(self): return Union[Mapping] diff --git a/python/knext/component/builder/mapping.py b/python/knext/component/builder/mapping.py index 2184be32..42ebee39 100644 --- a/python/knext/component/builder/mapping.py +++ b/python/knext/component/builder/mapping.py @@ -12,7 +12,6 @@ from knext.operator.op import LinkOp from knext.operator.spg_record import SPGRecord - class MappingTypeEnum(str, Enum): SPGType = "SPG_TYPE" Relation = "RELATION" @@ -67,7 +66,12 @@ class SPGTypeMapping(Mapping): def output_keys(self): return self.output_fields - def add_field(self, source_field: str, target_field: Union[str, PropertyHelper], link_strategy: Union[LinkStrategyEnum ,LinkOp] = None): + def add_field( + self, + source_field: str, + target_field: Union[str, PropertyHelper], + link_strategy: Union[LinkStrategyEnum, LinkOp] = None, + ): """Adds a field mapping from source data to property of spg_type. :param source_field: The source field to be mapped. @@ -94,7 +98,7 @@ class SPGTypeMapping(Mapping): Transforms `EntityMappingComponent` to REST model `MappingNodeConfig`. """ schema = {} - #TODO generate schema with link_strategy + # TODO generate schema with link_strategy mapping_filters = [ rest.MappingFilter(column_name=name, column_value=value) @@ -236,7 +240,12 @@ class SubGraphMapping(Mapping): def output_keys(self): return self.output_fields - def add_field(self, source_field: str, target_field: Union[str, PropertyHelper], link_strategy: Union[LinkStrategyEnum ,LinkOp] = None): + def add_field( + self, + source_field: str, + target_field: Union[str, PropertyHelper], + link_strategy: Union[LinkStrategyEnum, LinkOp] = None, + ): """Adds a field mapping from source data to property of spg_type. :param source_field: The source field to be mapped. @@ -282,4 +291,3 @@ class SubGraphMapping(Mapping): def submit(self): pass - diff --git a/python/knext/examples/medical/builder/job/hospital_department.py b/python/knext/examples/medical/builder/job/hospital_department.py index 8d82a749..442f4578 100644 --- a/python/knext/examples/medical/builder/job/hospital_department.py +++ b/python/knext/examples/medical/builder/job/hospital_department.py @@ -27,9 +27,7 @@ class HospitalDepartment(BuilderJob): start_row=1, ) - mapping = EntityMappingComponent( - spg_type_name=Medical.HospitalDepartment - ) + mapping = EntityMappingComponent(spg_type_name=Medical.HospitalDepartment) sink = SinkToKgComponent() diff --git a/python/knext/examples/riskmining/schema/riskmining_schema_helper.py b/python/knext/examples/riskmining/schema/riskmining_schema_helper.py index ddf2c1c7..c831b2cc 100644 --- a/python/knext/examples/riskmining/schema/riskmining_schema_helper.py +++ b/python/knext/examples/riskmining/schema/riskmining_schema_helper.py @@ -3,90 +3,90 @@ # PLEASE DO NOT MODIFY THIS FILE!!! # + class RiskMining: - def __init__(self): - self.App = self.App() - self.Cert = self.Cert() - self.Company = self.Company() - self.Device = self.Device() - self.Person = self.Person() - self.TaxOfRiskApp = self.TaxOfRiskApp() - self.TaxOfRiskUser = self.TaxOfRiskUser() + def __init__(self): + self.App = self.App() + self.Cert = self.Cert() + self.Company = self.Company() + self.Device = self.Device() + self.Person = self.Person() + self.TaxOfRiskApp = self.TaxOfRiskApp() + self.TaxOfRiskUser = self.TaxOfRiskUser() - class App: - __typename__ = "RiskMining.App" - description = "description" - id = "id" - name = "name" - belongTo = "belongTo" - useCert = "useCert" - riskMark = "riskMark" + class App: + __typename__ = "RiskMining.App" + description = "description" + id = "id" + name = "name" + belongTo = "belongTo" + useCert = "useCert" + riskMark = "riskMark" - def __init__(self): - pass + def __init__(self): + pass - class Cert: - __typename__ = "RiskMining.Cert" - description = "description" - id = "id" - name = "name" - certNum = "certNum" + class Cert: + __typename__ = "RiskMining.Cert" + description = "description" + id = "id" + name = "name" + certNum = "certNum" - def __init__(self): - pass + def __init__(self): + pass - class Company: - __typename__ = "RiskMining.Company" - description = "description" - id = "id" - name = "name" - hasPhone = "hasPhone" + class Company: + __typename__ = "RiskMining.Company" + description = "description" + id = "id" + name = "name" + hasPhone = "hasPhone" - def __init__(self): - pass + def __init__(self): + pass - class Device: - __typename__ = "RiskMining.Device" - description = "description" - id = "id" - name = "name" - install = "install" - umid = "umid" + class Device: + __typename__ = "RiskMining.Device" + description = "description" + id = "id" + name = "name" + install = "install" + umid = "umid" - def __init__(self): - pass + def __init__(self): + pass - class Person: - __typename__ = "RiskMining.Person" - description = "description" - id = "id" - name = "name" - hasPhone = "hasPhone" - belongTo = "belongTo" - age = "age" + class Person: + __typename__ = "RiskMining.Person" + description = "description" + id = "id" + name = "name" + hasPhone = "hasPhone" + belongTo = "belongTo" + age = "age" - def __init__(self): - pass + def __init__(self): + pass - class TaxOfRiskApp: - __typename__ = "RiskMining.TaxOfRiskApp" - description = "description" - id = "id" - name = "name" - alias = "alias" - stdId = "stdId" + class TaxOfRiskApp: + __typename__ = "RiskMining.TaxOfRiskApp" + description = "description" + id = "id" + name = "name" + alias = "alias" + stdId = "stdId" - def __init__(self): - pass + def __init__(self): + pass - class TaxOfRiskUser: - __typename__ = "RiskMining.TaxOfRiskUser" - description = "description" - id = "id" - name = "name" - alias = "alias" - stdId = "stdId" - - def __init__(self): - pass + class TaxOfRiskUser: + __typename__ = "RiskMining.TaxOfRiskUser" + description = "description" + id = "id" + name = "name" + alias = "alias" + stdId = "stdId" + def __init__(self): + pass diff --git a/python/knext/operator/builtin/online_runner.py b/python/knext/operator/builtin/online_runner.py index 33e55f5d..c1cc98bd 100644 --- a/python/knext/operator/builtin/online_runner.py +++ b/python/knext/operator/builtin/online_runner.py @@ -6,7 +6,6 @@ from NN4K.invoker.base import ModelInvoker class BuiltInOnlineLLMBasedExtractOp(ExtractOp): - def __init__(self, params: Dict[str, str] = None): """ diff --git a/python/knext/operator/op.py b/python/knext/operator/op.py index 758082bd..f1842deb 100644 --- a/python/knext/operator/op.py +++ b/python/knext/operator/op.py @@ -99,7 +99,9 @@ class PromptOp(ExtractOp, ABC): f"{self.__class__.__name__} need to implement `build_prompt` method." ) - def parse_response(self, response: str) -> Union[List[Dict[str, str]], List[SPGRecord]]: + def parse_response( + self, response: str + ) -> Union[List[Dict[str, str]], List[SPGRecord]]: raise NotImplementedError( f"{self.__class__.__name__} need to implement `parse_response` method." ) diff --git a/python/knext/operator/spg_record.py b/python/knext/operator/spg_record.py index b1ed103e..89364a41 100644 --- a/python/knext/operator/spg_record.py +++ b/python/knext/operator/spg_record.py @@ -17,9 +17,7 @@ from typing import Dict, Any, List class SPGRecord: """Data structure in operator, used to store entity information.""" - def __init__( - self, spg_type_name: str = "", properties: Dict[str, str] = None - ): + def __init__(self, spg_type_name: str = "", properties: Dict[str, str] = None): self._spg_type_name = None self._properties = None diff --git a/server/api/facade/pom.xml b/server/api/facade/pom.xml index d0dd24b2..d3a627cd 100644 --- a/server/api/facade/pom.xml +++ b/server/api/facade/pom.xml @@ -16,7 +16,7 @@ 4.0.0 com.antgroup.openspg.server - openspg-server-parent + server-parent 0.0.1-SNAPSHOT ../../pom.xml diff --git a/server/api/http-client/pom.xml b/server/api/http-client/pom.xml index 5fff850d..267c6849 100644 --- a/server/api/http-client/pom.xml +++ b/server/api/http-client/pom.xml @@ -16,7 +16,7 @@ 4.0.0 com.antgroup.openspg.server - openspg-server-parent + server-parent 0.0.1-SNAPSHOT ../../pom.xml diff --git a/server/api/http-server/pom.xml b/server/api/http-server/pom.xml index 2c2f63d1..503c7c09 100644 --- a/server/api/http-server/pom.xml +++ b/server/api/http-server/pom.xml @@ -16,7 +16,7 @@ 4.0.0 com.antgroup.openspg.server - openspg-server-parent + server-parent 0.0.1-SNAPSHOT ../../pom.xml diff --git a/server/arks/sofaboot/pom.xml b/server/arks/sofaboot/pom.xml index f6f6f167..8e6ff8e6 100644 --- a/server/arks/sofaboot/pom.xml +++ b/server/arks/sofaboot/pom.xml @@ -16,7 +16,7 @@ 4.0.0 com.antgroup.openspg.server - openspg-server-parent + server-parent 0.0.1-SNAPSHOT ../../pom.xml diff --git a/server/biz/common/pom.xml b/server/biz/common/pom.xml index d70895d1..9be0f067 100644 --- a/server/biz/common/pom.xml +++ b/server/biz/common/pom.xml @@ -16,7 +16,7 @@ 4.0.0 com.antgroup.openspg.server - openspg-server-parent + server-parent 0.0.1-SNAPSHOT ../../pom.xml diff --git a/server/biz/reasoner/pom.xml b/server/biz/reasoner/pom.xml index 89aec95b..a06d34b9 100644 --- a/server/biz/reasoner/pom.xml +++ b/server/biz/reasoner/pom.xml @@ -16,7 +16,7 @@ 4.0.0 com.antgroup.openspg.server - openspg-server-parent + server-parent 0.0.1-SNAPSHOT ../../pom.xml diff --git a/server/biz/schema/pom.xml b/server/biz/schema/pom.xml index 5bb7c8aa..d46d8ff6 100644 --- a/server/biz/schema/pom.xml +++ b/server/biz/schema/pom.xml @@ -16,7 +16,7 @@ 4.0.0 com.antgroup.openspg.server - openspg-server-parent + server-parent 0.0.1-SNAPSHOT ../../pom.xml diff --git a/server/cloudext/impl/computing/local/pom.xml b/server/cloudext/impl/computing/local/pom.xml index e604e9e6..da8cc399 100644 --- a/server/cloudext/impl/computing/local/pom.xml +++ b/server/cloudext/impl/computing/local/pom.xml @@ -16,7 +16,7 @@ 4.0.0 com.antgroup.openspg.server - openspg-server-parent + server-parent 0.0.1-SNAPSHOT ../../../../pom.xml @@ -29,7 +29,7 @@ cloudext-interface-computing - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-interface-table-store diff --git a/server/cloudext/impl/job-scheduler/local/pom.xml b/server/cloudext/impl/job-scheduler/local/pom.xml index e1a8e0ad..567ac994 100644 --- a/server/cloudext/impl/job-scheduler/local/pom.xml +++ b/server/cloudext/impl/job-scheduler/local/pom.xml @@ -16,7 +16,7 @@ 4.0.0 com.antgroup.openspg.server - openspg-server-parent + server-parent 0.0.1-SNAPSHOT ../../../../pom.xml diff --git a/server/cloudext/interface/computing/pom.xml b/server/cloudext/interface/computing/pom.xml index e466bd74..799b5f23 100644 --- a/server/cloudext/interface/computing/pom.xml +++ b/server/cloudext/interface/computing/pom.xml @@ -16,7 +16,7 @@ 4.0.0 com.antgroup.openspg.server - openspg-server-parent + server-parent 0.0.1-SNAPSHOT ../../../pom.xml diff --git a/server/cloudext/interface/job-scheduler/pom.xml b/server/cloudext/interface/job-scheduler/pom.xml index ed1172ad..b08bd31a 100644 --- a/server/cloudext/interface/job-scheduler/pom.xml +++ b/server/cloudext/interface/job-scheduler/pom.xml @@ -16,7 +16,7 @@ 4.0.0 com.antgroup.openspg.server - openspg-server-parent + server-parent 0.0.1-SNAPSHOT ../../../pom.xml diff --git a/server/common/model/pom.xml b/server/common/model/pom.xml index 329f1814..c8ead0bb 100644 --- a/server/common/model/pom.xml +++ b/server/common/model/pom.xml @@ -16,7 +16,7 @@ 4.0.0 com.antgroup.openspg.server - openspg-server-parent + server-parent 0.0.1-SNAPSHOT ../../pom.xml diff --git a/server/common/service/pom.xml b/server/common/service/pom.xml index 266978ae..79f86148 100644 --- a/server/common/service/pom.xml +++ b/server/common/service/pom.xml @@ -16,7 +16,7 @@ 4.0.0 com.antgroup.openspg.server - openspg-server-parent + server-parent 0.0.1-SNAPSHOT ../../pom.xml @@ -33,15 +33,15 @@ api-http-client - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-interface-graph-store - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-interface-object-store - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-interface-search-engine @@ -53,7 +53,7 @@ cloudext-interface-computing - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-interface-table-store diff --git a/server/core/reasoner/model/pom.xml b/server/core/reasoner/model/pom.xml index bfb2cfd0..5d74ea75 100644 --- a/server/core/reasoner/model/pom.xml +++ b/server/core/reasoner/model/pom.xml @@ -16,7 +16,7 @@ 4.0.0 com.antgroup.openspg.server - openspg-server-parent + server-parent 0.0.1-SNAPSHOT ../../../pom.xml diff --git a/server/core/reasoner/service/pom.xml b/server/core/reasoner/service/pom.xml index 51af7c27..3b86f0bb 100644 --- a/server/core/reasoner/service/pom.xml +++ b/server/core/reasoner/service/pom.xml @@ -16,7 +16,7 @@ 4.0.0 com.antgroup.openspg.server - openspg-server-parent + server-parent 0.0.1-SNAPSHOT ../../../pom.xml diff --git a/server/core/schema/model/pom.xml b/server/core/schema/model/pom.xml index 45290b29..716a61fe 100644 --- a/server/core/schema/model/pom.xml +++ b/server/core/schema/model/pom.xml @@ -16,7 +16,7 @@ 4.0.0 com.antgroup.openspg.server - openspg-server-parent + server-parent 0.0.1-SNAPSHOT ../../../pom.xml diff --git a/server/core/schema/service/pom.xml b/server/core/schema/service/pom.xml index 8db8381d..ab64766a 100644 --- a/server/core/schema/service/pom.xml +++ b/server/core/schema/service/pom.xml @@ -16,7 +16,7 @@ 4.0.0 com.antgroup.openspg.server - openspg-server-parent + server-parent 0.0.1-SNAPSHOT ../../../pom.xml @@ -33,19 +33,19 @@ common-service - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-impl-graph-store-tugraph - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-impl-object-store-local - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-impl-table-store-local - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-impl-search-engine-elasticsearch diff --git a/server/infra/dao/pom.xml b/server/infra/dao/pom.xml index 465227d7..0645d8b5 100644 --- a/server/infra/dao/pom.xml +++ b/server/infra/dao/pom.xml @@ -16,7 +16,7 @@ 4.0.0 com.antgroup.openspg.server - openspg-server-parent + server-parent 0.0.1-SNAPSHOT ../../pom.xml diff --git a/server/pom.xml b/server/pom.xml index 38b1b329..533cf8aa 100644 --- a/server/pom.xml +++ b/server/pom.xml @@ -23,7 +23,7 @@ com.antgroup.openspg.server - openspg-server-parent + server-parent 0.0.1-SNAPSHOT pom diff --git a/server/test/pom.xml b/server/test/pom.xml index e8c6ee1a..e99aa0e5 100644 --- a/server/test/pom.xml +++ b/server/test/pom.xml @@ -16,7 +16,7 @@ 4.0.0 com.antgroup.openspg.server - openspg-server-parent + server-parent 0.0.1-SNAPSHOT @@ -40,7 +40,7 @@ test - com.antgroup.openspg + com.antgroup.openspg.cloudext cloudext-impl-graph-store-tugraph test