fix(postgres): schema name (#230)

opendatadiscovery · Oct 2, 2023 · 6e6fc1f · 6e6fc1f
1 parent 4d5e064
commit 6e6fc1f
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/odd_collector/adapters/postgresql/mappers/schemas.py b/odd_collector/adapters/postgresql/mappers/schemas.py
@@ -1,5 +1,5 @@
 from funcy import lpluck_attr
-from odd_collector_sdk.utils.metadata import extract_metadata, DefinitionType
+from odd_collector_sdk.utils.metadata import DefinitionType, extract_metadata
 from odd_models import DataEntity, DataEntityGroup, DataEntityType
 from oddrn_generator import PostgresqlGenerator
 
@@ -10,9 +10,10 @@ def map_schema(
     generator: PostgresqlGenerator, schema: Schema, table_entities: list[DataEntity]
 ) -> DataEntity:
     return DataEntity(
-        oddrn=generator.get_oddrn_by_path("schemas"),
+        oddrn=generator.get_oddrn_by_path("schemas", schema.schema_name),
         name=schema.schema_name,
         type=DataEntityType.DATABASE_SERVICE,
+        owner=None,
         metadata=[extract_metadata("postgres", schema, DefinitionType.DATASET)],
         data_entity_group=DataEntityGroup(
             entities_list=lpluck_attr("oddrn", table_entities)