Skip to content

Commit 443cb0c

Browse files
committed
fix
1 parent 7dee94f commit 443cb0c

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

launch/model_endpoint.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -336,12 +336,13 @@ def predict(self, request: EndpointRequest) -> EndpointResponseFuture:
336336
f: EndpointResponseFuture = my_endpoint.predict(EndpointRequest(...))
337337
result = f.get() # blocks on completion
338338
"""
339-
async_task_id = self.client._async_request( # pylint: disable=W0212
339+
response = self.client._async_request( # pylint: disable=W0212
340340
self.model_endpoint.name,
341341
url=request.url,
342342
args=request.args,
343343
return_pickled=request.return_pickled,
344344
)
345+
async_task_id = response.task_id
345346
return EndpointResponseFuture(
346347
client=self.client,
347348
endpoint_name=self.model_endpoint.name,
@@ -471,7 +472,7 @@ def single_request(inner_url, inner_task_id):
471472
if raw_response:
472473
response_object = EndpointResponse(
473474
client=self.client,
474-
status=raw_response["status"],
475+
status=raw_response["status"].value,
475476
result_url=raw_response.get("result_url", None),
476477
result=raw_response.get("result", None),
477478
traceback=raw_response.get("traceback", None),

0 commit comments

Comments
 (0)