Skip to content

Commit f34a0fa

Browse files
committed
fix openapi migrate issues: v1.job.create -> pre_create
1 parent c615ebb commit f34a0fa

File tree

1 file changed

+6
-2
lines changed
  • src/bohrium/resources/job

1 file changed

+6
-2
lines changed

src/bohrium/resources/job/job.py

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -87,7 +87,8 @@ def log(self, job_id, log_file="STDOUTERR", page=-1, page_size=8192):
8787
# log.info(f"log job {job_id}")
8888
response = self._client.get(f"/openapi/v1/job/{job_id}/log", params={"logFile": log_file, "page": page, "pageSize": page_size})
8989
pprint(response.request)
90-
print(response.json())
90+
print(response.json().get("data")["log"])
91+
return response.json().get("data")["log"]
9192

9293
def detail(self, job_id):
9394
# log.info(f"detail job {job_id}")
@@ -103,12 +104,15 @@ def create_job(
103104
group_id: Optional[int] = 0,
104105
):
105106
# log.info(f"create job {name}")
107+
response = self._client.get(f"/openapi/v1/ak/get")
108+
106109
data = {
110+
"userId": response.json().get("data").get("user_id"),
107111
"projectId": project_id,
108112
"name": name,
109113
"bohrGroupId": group_id,
110114
}
111-
response = self._client.post(f"/openapi/v1/job/create", json=data)
115+
response = self._client.post(f"/openapi/v1/job/pre_create", json=data)
112116
pprint(response.request)
113117
print(response.json())
114118
return response.json().get("data")

0 commit comments

Comments
 (0)