File tree Expand file tree Collapse file tree 2 files changed +4
-9
lines changed Expand file tree Collapse file tree 2 files changed +4
-9
lines changed Original file line number Diff line number Diff line change @@ -1171,14 +1171,7 @@ def create_custom_index(
1171
1171
f"indexing/{ dataset_id } " ,
1172
1172
requests_command = requests .post ,
1173
1173
)
1174
-
1175
- job = AsyncJob (
1176
- job_id = response_objects [JOB_ID_KEY ],
1177
- job_last_known_status = response_objects [JOB_STATUS_KEY ],
1178
- job_type = response_objects [JOB_TYPE_KEY ],
1179
- job_creation_time = response_objects [JOB_CREATION_TIME_KEY ],
1180
- client = self ,
1181
- )
1174
+ job = AsyncJob .from_json (response_objects , self )
1182
1175
dataset_id = response_objects [DATASET_ID_KEY ]
1183
1176
message = response_objects [MESSAGE_KEY ]
1184
1177
Original file line number Diff line number Diff line change @@ -21,11 +21,13 @@ class AsyncJob:
21
21
client : "NucleusClient" # type: ignore # noqa: F821
22
22
23
23
def status (self ) -> Dict [str , str ]:
24
- return self .client .make_request (
24
+ response = self .client .make_request (
25
25
payload = {},
26
26
route = f"job/{ self .job_id } " ,
27
27
requests_command = requests .get ,
28
28
)
29
+ self .job_last_known_status = response ["job_status" ]
30
+ return response
29
31
30
32
def errors (self ) -> List [str ]:
31
33
return self .client .make_request (
You can’t perform that action at this time.
0 commit comments