fix(api): 🐛 resolve indentation issues in generate.py
This commit is contained in:
parent
415be2db69
commit
7c06012c7c
1 changed files with 4 additions and 4 deletions
|
|
@ -240,7 +240,7 @@ async def generate_async(request: GenerateRequest, req: Request):
|
|||
# Mark as running
|
||||
await job_storage.update_status(
|
||||
job.id,
|
||||
JobStatus.RUNNING,
|
||||
StorageJobStatus.RUNNING,
|
||||
current_stage="generate",
|
||||
)
|
||||
|
||||
|
|
@ -253,13 +253,13 @@ async def generate_async(request: GenerateRequest, req: Request):
|
|||
await job_storage.set_result(job.id, _context_to_result(result))
|
||||
await job_storage.update_status(
|
||||
job.id,
|
||||
JobStatus.COMPLETED,
|
||||
StorageJobStatus.COMPLETED,
|
||||
stages_completed=len(result.stage_results),
|
||||
)
|
||||
else:
|
||||
await job_storage.update_status(
|
||||
job.id,
|
||||
JobStatus.FAILED,
|
||||
StorageJobStatus.FAILED,
|
||||
error=result.error or "Pipeline failed",
|
||||
)
|
||||
|
||||
|
|
@ -267,7 +267,7 @@ async def generate_async(request: GenerateRequest, req: Request):
|
|||
logger.error(f"Job {job.id} failed: {e}", exc_info=True)
|
||||
await job_storage.update_status(
|
||||
job.id,
|
||||
JobStatus.FAILED,
|
||||
StorageJobStatus.FAILED,
|
||||
error=str(e),
|
||||
)
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue