diff --git a/functions-python/gbfs_validator/src/gbfs_data_processor.py b/functions-python/gbfs_validator/src/gbfs_data_processor.py index bfb47c769..91873a832 100644 --- a/functions-python/gbfs_validator/src/gbfs_data_processor.py +++ b/functions-python/gbfs_validator/src/gbfs_data_processor.py @@ -368,6 +368,9 @@ def create_validation_report_entities( validation_report_url = validation_report_data.get("report_summary_url") validation_report_json = validation_report_data.get("json_report_summary") validation_time = validation_report_data.get("validation_time") + if not validation_report_url: + self.logger.error("Validation report doesn't exist") + return None validator_version = validation_report_json.get("summary", {}).get( "validatorVersion", None diff --git a/functions-python/reverse_geolocation/src/reverse_geolocation_processor.py b/functions-python/reverse_geolocation/src/reverse_geolocation_processor.py index 3a1dda9bc..430776197 100644 --- a/functions-python/reverse_geolocation/src/reverse_geolocation_processor.py +++ b/functions-python/reverse_geolocation/src/reverse_geolocation_processor.py @@ -178,6 +178,8 @@ def extract_location_aggregate( group_name=", ".join([g.name for g in geopolygons]), osms=geopolygons, ) + db_session.add(group) + db_session.flush() # Ensure the group is added before using it stop = ( db_session.query(Feedlocationgrouppoint) .filter(