@@ -119,7 +119,6 @@ def get_model_run(self, model_run_id: str) -> ModelRun:
119
119
"""
120
120
return ModelRun (model_run_id , self )
121
121
122
-
123
122
def delete_model_run (self , model_run_id : str ):
124
123
"""
125
124
Fetches a model_run for given id
@@ -220,7 +219,6 @@ def preprocess_payload(item):
220
219
}
221
220
return payload
222
221
223
- session = requests .session ()
224
222
items = payload [ITEMS_KEY ]
225
223
responses : List [Any ] = []
226
224
for i in range (0 , len (items ), batch_size ):
@@ -231,7 +229,6 @@ def preprocess_payload(item):
231
229
self ._make_grequest (
232
230
payload ,
233
231
f"dataset/{ dataset_id } /append" ,
234
- session = session ,
235
232
local = True ,
236
233
)
237
234
for payload in payloads
@@ -273,7 +270,6 @@ def exception_handler(request, exception):
273
270
logger .error (request , exception )
274
271
return default_error (request .json ())
275
272
276
- session = requests .session ()
277
273
items = payload [ITEMS_KEY ]
278
274
payloads = [
279
275
{ITEMS_KEY : items [i : i + batch_size ]}
@@ -284,7 +280,6 @@ def exception_handler(request, exception):
284
280
self ._make_grequest (
285
281
payload ,
286
282
f"dataset/{ dataset_id } /append" ,
287
- session = session ,
288
283
local = False ,
289
284
)
290
285
for payload in payloads
@@ -613,7 +608,7 @@ def _make_grequest(
613
608
self ,
614
609
payload : dict ,
615
610
route : str ,
616
- session ,
611
+ session = None ,
617
612
requests_command : Callable = grequests .post ,
618
613
local = True ,
619
614
):
0 commit comments