Skip to content

Commit

Permalink
Last updates
Browse files Browse the repository at this point in the history
  • Loading branch information
dcvz committed Oct 13, 2023
1 parent f9865fd commit 8974f76
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions modules/api/api.py
Original file line number Diff line number Diff line change
Expand Up @@ -221,7 +221,7 @@ def __init__(self, app: FastAPI, queue_lock: Lock):
self.add_api_route("/sdapi/v1/png-info", self.pnginfoapi, methods=["POST"], response_model=models.PNGInfoResponse)
self.add_api_route("/sdapi/v1/progress", self.progressapi, methods=["GET"], response_model=models.ProgressResponse)

self.add_api_route("/sdapi/v1/new-progress", self.newprogressapi, methods=["POST"], response_model=NewProgressResponse)
self.add_api_route("/sdapi/v1/new-progress", self.newprogressapi, methods=["POST"], response_model=models.NewProgressResponse)
self.add_api_route("/sdapi/v1/cancel", self.cancel, methods=["POST"])

self.add_api_route("/sdapi/v1/interrogate", self.interrogateapi, methods=["POST"])
Expand Down Expand Up @@ -532,14 +532,14 @@ def progressapi(self, req: models.ProgressRequest = Depends()):

return models.ProgressResponse(progress=progress, eta_relative=eta_relative, state=shared.state.dict(), current_image=current_image, textinfo=shared.state.textinfo)

def newprogressapi(self, req: NewProgressRequest):
def newprogressapi(self, req: models.NewProgressRequest):
active = req.id_task == jobs.current_task
queued = req.id_task in jobs.pending_tasks
completed = req.id_task in jobs.finished_tasks

if not active:
position_in_queue = sum(1 for job_id, timestamp in jobs.pending_tasks.items() if timestamp < jobs.pending_tasks[req.id_task]) + 1
return NewProgressResponse(active=active, queued=queued, completed=completed, eta=position_in_queue, textinfo="In queue..." if queued else "Waiting...")
return models.NewProgressResponse(active=active, queued=queued, completed=completed, eta=position_in_queue, textinfo="In queue..." if queued else "Waiting...")

progress = 0

Expand Down Expand Up @@ -567,9 +567,9 @@ def newprogressapi(self, req: NewProgressRequest):
else:
live_preview = None

return NewProgressResponse(active=active, queued=queued, completed=completed, progress=progress, eta=eta, live_preview=live_preview, textinfo=shared.state.textinfo)
return models.NewProgressResponse(active=active, queued=queued, completed=completed, progress=progress, eta=eta, live_preview=live_preview, textinfo=shared.state.textinfo)

def cancel(self, req: CancelRequest):
def cancel(self, req: models.CancelRequest):
if req.id_task == jobs.current_task:
shared.state.interrupt()

Expand Down

0 comments on commit 8974f76

Please sign in to comment.