Skip to content

Commit

Permalink
Merge branch 'zane-fix-server-bug' into zane-concrete-values
Browse files Browse the repository at this point in the history
  • Loading branch information
zaneenders committed Oct 15, 2024
2 parents a94bb07 + ffa2b46 commit 22f20fd
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions src/api/server.rkt
Original file line number Diff line number Diff line change
Expand Up @@ -242,11 +242,11 @@
(hash-set! current-jobs (work-item-id job) wid)
(place-channel-put worker (list 'apply self (work-item-command job) (work-item-id job)))
(hash-set! reassigned wid worker)
(hash-set! busy-workers wid worker))
; remove X many jobs from the Q and update waiting-workers
(for ([(wid worker) (in-hash reassigned)])
(hash-remove! waiting-workers wid)
(set! job-queue (cdr job-queue))))]
(hash-set! busy-workers wid worker)))
; remove X many jobs from the Q and update waiting-workers
(for ([(wid worker) (in-hash reassigned)])
(hash-remove! waiting-workers wid)
(set! job-queue (cdr job-queue)))]
; Job is finished save work and free worker. Move work to 'send state.
[(list 'finished self wid job-id result)
(log "Job ~a finished, saving result.\n" job-id)
Expand Down

0 comments on commit 22f20fd

Please sign in to comment.