Skip to content

Commit c8b5c07

Browse files
pre-commit-ci[bot]pre-commit-ci[bot]
committed
[pre-commit.ci] auto fixes from pre-commit.com hooks
for more information, see https://pre-commit.ci
1 parent 508c5d9 commit c8b5c07

File tree

1 file changed

+34
-102
lines changed

1 file changed

+34
-102
lines changed

‎jupyter_scheduler/handlers.py‎

Lines changed: 34 additions & 102 deletions
Original file line numberDiff line numberDiff line change
@@ -170,27 +170,19 @@ async def post(self):
170170
)
171171
except ValidationError as e:
172172
self.log.exception(e)
173-
raise HTTPError(
174-
500, f"Unexpected error during creation of job definition: {e}"
175-
) from e
173+
raise HTTPError(500, f"Unexpected error during creation of job definition: {e}") from e
176174
except InputUriError as e:
177175
self.log.exception(e)
178-
raise HTTPError(
179-
500, f"Unexpected error during creation of job definition: {e}"
180-
) from e
176+
raise HTTPError(500, f"Unexpected error during creation of job definition: {e}") from e
181177
except SchedulerError as e:
182178
self.log.exception(e)
183-
raise HTTPError(
184-
500, f"Unexpected error during creation of job definition: {e}"
185-
) from e
179+
raise HTTPError(500, f"Unexpected error during creation of job definition: {e}") from e
186180
except HTTPError:
187181
# Re-raise HTTPError as-is (e.g., 400 for invalid backend)
188182
raise
189183
except Exception as e:
190184
self.log.exception(e)
191-
raise HTTPError(
192-
500, f"Unexpected error during creation of job definition: {e}"
193-
) from e
185+
raise HTTPError(500, f"Unexpected error during creation of job definition: {e}") from e
194186
else:
195187
self.finish(json.dumps(dict(job_definition_id=job_definition_id)))
196188

@@ -205,19 +197,13 @@ async def patch(self, job_definition_id):
205197
)
206198
except ValidationError as e:
207199
self.log.exception(e)
208-
raise HTTPError(
209-
500, f"Unexpected error while updating the job definition: {e}"
210-
) from e
200+
raise HTTPError(500, f"Unexpected error while updating the job definition: {e}") from e
211201
except SchedulerError as e:
212202
self.log.exception(e)
213-
raise HTTPError(
214-
500, f"Unexpected error while updating the job definition: {e}"
215-
) from e
203+
raise HTTPError(500, f"Unexpected error while updating the job definition: {e}") from e
216204
except Exception as e:
217205
self.log.exception(e)
218-
raise HTTPError(
219-
500, f"Unexpected error while updating the job definition: {e}"
220-
) from e
206+
raise HTTPError(500, f"Unexpected error while updating the job definition: {e}") from e
221207
else:
222208
self.set_status(204)
223209
self.finish()
@@ -228,14 +214,10 @@ async def delete(self, job_definition_id):
228214
await ensure_async(self.scheduler.delete_job_definition(job_definition_id))
229215
except SchedulerError as e:
230216
self.log.exception(e)
231-
raise HTTPError(
232-
500, f"Unexpected error while deleting the job definition: {e}"
233-
) from e
217+
raise HTTPError(500, f"Unexpected error while deleting the job definition: {e}") from e
234218
except Exception as e:
235219
self.log.exception(e)
236-
raise HTTPError(
237-
500, f"Unexpected error while deleting the job definition: {e}"
238-
) from e
220+
raise HTTPError(500, f"Unexpected error while deleting the job definition: {e}") from e
239221
else:
240222
self.set_status(204)
241223
self.finish()
@@ -253,14 +235,10 @@ async def get(self, job_id=None):
253235
job.backend_id = self.backend_registry.get_legacy_job_backend().config.id
254236
except SchedulerError as e:
255237
self.log.exception(e)
256-
raise HTTPError(
257-
500, f"Unexpected error while getting job details: {e}"
258-
) from e
238+
raise HTTPError(500, f"Unexpected error while getting job details: {e}") from e
259239
except Exception as e:
260240
self.log.exception(e)
261-
raise HTTPError(
262-
500, f"Unexpected error while getting job details: {e}"
263-
) from e
241+
raise HTTPError(500, f"Unexpected error while getting job details: {e}") from e
264242
else:
265243
self.finish(job.json())
266244
else:
@@ -311,19 +289,13 @@ async def get(self, job_id=None):
311289
self.log.warning(f"Failed to sync status for job {job.job_id}: {e}")
312290
except ValidationError as e:
313291
self.log.exception(e)
314-
raise HTTPError(
315-
500, f"Unexpected error while getting jobs list: {e}"
316-
) from e
292+
raise HTTPError(500, f"Unexpected error while getting jobs list: {e}") from e
317293
except SchedulerError as e:
318294
self.log.exception(e)
319-
raise HTTPError(
320-
500, f"Unexpected error while getting jobs list: {e}"
321-
) from e
295+
raise HTTPError(500, f"Unexpected error while getting jobs list: {e}") from e
322296
except Exception as e:
323297
self.log.exception(e)
324-
raise HTTPError(
325-
500, f"Unexpected error while getting jobs list: {e}"
326-
) from e
298+
raise HTTPError(500, f"Unexpected error while getting jobs list: {e}") from e
327299
else:
328300
self.finish(list_jobs_response.json(exclude_none=True))
329301

@@ -344,30 +316,22 @@ async def post(self):
344316
# Job ID is already in backend:uuid format from scheduler (no wrapping needed)
345317
except ValidationError as e:
346318
self.log.exception(e)
347-
raise HTTPError(
348-
500, f"Unexpected error during creation of job: {e}"
349-
) from e
319+
raise HTTPError(500, f"Unexpected error during creation of job: {e}") from e
350320
except InputUriError as e:
351321
self.log.exception(e)
352-
raise HTTPError(
353-
500, f"Unexpected error during creation of job: {e}"
354-
) from e
322+
raise HTTPError(500, f"Unexpected error during creation of job: {e}") from e
355323
except IdempotencyTokenError as e:
356324
self.log.exception(e)
357325
raise HTTPError(409, str(e)) from e
358326
except SchedulerError as e:
359327
self.log.exception(e)
360-
raise HTTPError(
361-
500, f"Unexpected error during creation of job: {e}"
362-
) from e
328+
raise HTTPError(500, f"Unexpected error during creation of job: {e}") from e
363329
except HTTPError:
364330
# Re-raise HTTPError as-is (e.g., 400 for invalid backend)
365331
raise
366332
except Exception as e:
367333
self.log.exception(e)
368-
raise HTTPError(
369-
500, f"Unexpected error during creation of job: {e}"
370-
) from e
334+
raise HTTPError(500, f"Unexpected error during creation of job: {e}") from e
371335
else:
372336
response = {"job_id": job_id}
373337
if "backend_id" in payload:
@@ -395,19 +359,13 @@ async def patch(self, job_id):
395359
await ensure_async(scheduler.update_job(job_id, UpdateJob(**payload)))
396360
except ValidationError as e:
397361
self.log.exception(e)
398-
raise HTTPError(
399-
500, f"Unexpected error while updating the job: {e}"
400-
) from e
362+
raise HTTPError(500, f"Unexpected error while updating the job: {e}") from e
401363
except SchedulerError as e:
402364
self.log.exception(e)
403-
raise HTTPError(
404-
500, f"Unexpected error while updating the job: {e}"
405-
) from e
365+
raise HTTPError(500, f"Unexpected error while updating the job: {e}") from e
406366
except Exception as e:
407367
self.log.exception(e)
408-
raise HTTPError(
409-
500, f"Unexpected error while updating the job: {e}"
410-
) from e
368+
raise HTTPError(500, f"Unexpected error while updating the job: {e}") from e
411369
else:
412370
self.set_status(204)
413371
self.finish()
@@ -419,14 +377,10 @@ async def delete(self, job_id):
419377
await ensure_async(scheduler.delete_job(job_id))
420378
except SchedulerError as e:
421379
self.log.exception(e)
422-
raise HTTPError(
423-
500, f"Unexpected error while deleting the job: {e}"
424-
) from e
380+
raise HTTPError(500, f"Unexpected error while deleting the job: {e}") from e
425381
except Exception as e:
426382
self.log.exception(e)
427-
raise HTTPError(
428-
500, f"Unexpected error while deleting the job: {e}"
429-
) from e
383+
raise HTTPError(500, f"Unexpected error while deleting the job: {e}") from e
430384
else:
431385
self.set_status(204)
432386
self.finish()
@@ -443,19 +397,13 @@ async def post(self, job_definition_id: str):
443397
)
444398
except ValidationError as e:
445399
self.log.exception(e)
446-
raise HTTPError(
447-
500, f"Unexpected error during creation of job: {e}"
448-
) from e
400+
raise HTTPError(500, f"Unexpected error during creation of job: {e}") from e
449401
except SchedulerError as e:
450402
self.log.exception(e)
451-
raise HTTPError(
452-
500, f"Unexpected error during creation of job: {e}"
453-
) from e
403+
raise HTTPError(500, f"Unexpected error during creation of job: {e}") from e
454404
except Exception as e:
455405
self.log.exception(e)
456-
raise HTTPError(
457-
500, f"Unexpected error during creation of job: {e}"
458-
) from e
406+
raise HTTPError(500, f"Unexpected error during creation of job: {e}") from e
459407
else:
460408
self.finish(json.dumps(dict(job_id=job_id)))
461409

@@ -470,14 +418,10 @@ async def delete(self):
470418
await ensure_async(scheduler.delete_job(job_id))
471419
except SchedulerError as e:
472420
self.log.exception(e)
473-
raise HTTPError(
474-
500, f"Unexpected error during deletion of jobs: {e}"
475-
) from e
421+
raise HTTPError(500, f"Unexpected error during deletion of jobs: {e}") from e
476422
except Exception as e:
477423
self.log.exception(e)
478-
raise HTTPError(
479-
500, f"Unexpected error during deletion of jobs: {e}"
480-
) from e
424+
raise HTTPError(500, f"Unexpected error during deletion of jobs: {e}") from e
481425
else:
482426
self.set_status(204)
483427
self.finish()
@@ -494,14 +438,10 @@ async def get(self):
494438
count = await ensure_async(self.scheduler.count_jobs(count_jobs_query))
495439
except SchedulerError as e:
496440
self.log.exception(e)
497-
raise HTTPError(
498-
500, f"Unexpected error while getting job count: {e}"
499-
) from e
441+
raise HTTPError(500, f"Unexpected error while getting job count: {e}") from e
500442
except Exception as e:
501443
self.log.exception(e)
502-
raise HTTPError(
503-
500, f"Unexpected error while getting job count: {e}"
504-
) from e
444+
raise HTTPError(500, f"Unexpected error while getting job count: {e}") from e
505445
else:
506446
self.finish(json.dumps(dict(count=count)))
507447

@@ -514,9 +454,7 @@ async def get(self):
514454
environments = await ensure_async(self.environments_manager.list_environments())
515455
output_formats = await ensure_async(self.environments_manager.output_formats_mapping())
516456
except EnvironmentRetrievalError as e:
517-
raise HTTPError(
518-
500, f"Unexpected error while listing environments: {e}"
519-
)
457+
raise HTTPError(500, f"Unexpected error while listing environments: {e}")
520458

521459
response = []
522460
for environment in environments:
@@ -565,9 +503,7 @@ async def get(self, job_id):
565503
await self.job_files_manager.copy_from_staging(job_id=job_id, redownload=redownload)
566504
except Exception as e:
567505
self.log.exception(e)
568-
raise HTTPError(
569-
500, f"Unexpected error while downloading files: {e}"
570-
) from e
506+
raise HTTPError(500, f"Unexpected error while downloading files: {e}") from e
571507
else:
572508
self.set_status(204)
573509
self.finish()
@@ -591,11 +527,7 @@ async def get(self):
591527
self.finish(json.dumps([b.dict() for b in backends]))
592528
except SchedulerError as e:
593529
self.log.exception(e)
594-
raise HTTPError(
595-
500, f"Unexpected error while listing backends: {e}"
596-
) from e
530+
raise HTTPError(500, f"Unexpected error while listing backends: {e}") from e
597531
except Exception as e:
598532
self.log.exception(e)
599-
raise HTTPError(
600-
500, f"Unexpected error while listing backends: {e}"
601-
) from e
533+
raise HTTPError(500, f"Unexpected error while listing backends: {e}") from e

0 commit comments

Comments
 (0)