diff --git a/src/ingest_data.py b/src/ingest_data.py index d9f2918..65da995 100644 --- a/src/ingest_data.py +++ b/src/ingest_data.py @@ -119,6 +119,10 @@ def insert_entity(self, entity: Dict) -> Optional[str]: coordinates["latitude"], ], } + elif entity["coordinates"] is None: + logger.warning( + f"Coordinates are None for entity: {entity.get('name', entity.get('id', 'unnamed'))}" + ) else: logger.error( f"Invalid coordinates format for entity: {entity.get('name', entity.get('id', 'unnamed'))}"