diff --git a/osm_rawdata/postgres.py b/osm_rawdata/postgres.py index 5f7a929..4cde6b0 100755 --- a/osm_rawdata/postgres.py +++ b/osm_rawdata/postgres.py @@ -501,6 +501,11 @@ def queryRemote( elif result_json.get("status") == "SUCCESS": break + else: + # Maximum polling duration reached + log.error(f"{max_polling_duration} second elapsed. Aborting data extract.") + return None + zip_url = result_json["result"]["download_url"] result = self.session.get(zip_url, headers=self.headers) fp = BytesIO(result.content)