@@ -126,7 +126,8 @@ def get_era5(latitude, longitude, start, end, variables, api_key,
126126 }
127127 }
128128 slug = "processes/reanalysis-era5-single-levels-timeseries/execution"
129- response = requests .post (url + slug , json = params , headers = headers )
129+ response = requests .post (url + slug , json = params , headers = headers ,
130+ timeout = timeout )
130131 submission_response = response .json ()
131132 if not response .ok :
132133 raise Exception (submission_response ) # likely need to accept license
@@ -138,7 +139,7 @@ def get_era5(latitude, longitude, start, end, variables, api_key,
138139 poll_interval = 1
139140 num_polls = 0
140141 while True :
141- response = requests .get (url + slug , headers = headers )
142+ response = requests .get (url + slug , headers = headers , timeout = timeout )
142143 poll_response = response .json ()
143144 job_status = poll_response ['status' ]
144145
@@ -162,12 +163,12 @@ def get_era5(latitude, longitude, start, end, variables, api_key,
162163
163164 # Step 3: get the download link for our requested dataset
164165 slug = "jobs/" + job_id + "/results"
165- response = requests .get (url + slug , headers = headers )
166+ response = requests .get (url + slug , headers = headers , timeout = timeout )
166167 results_response = response .json ()
167168 download_url = results_response ['asset' ]['value' ]['href' ]
168169
169170 # Step 4: finally, download our dataset. it's a zipfile of one CSV
170- response = requests .get (download_url )
171+ response = requests .get (download_url , timeout = timeout )
171172 zipbuffer = BytesIO (response .content )
172173 archive = zipfile .ZipFile (zipbuffer )
173174 filename = archive .filelist [0 ].filename
0 commit comments