Expire jobs if context is canceled

core/agent/agent.go

@@ -391,6 +391,13 @@ func (a *Agent) processUserInputs(job *types.Job, role string, conv Messages) Me
 }
 
 func (a *Agent) consumeJob(job *types.Job, role string) {
+
+
+ if err := job.GetContext().Err(); err != nil {
+   job.Result.Finish("expired"))
+   return
+ }
+
 	a.Lock()
 	paused := a.pause
 	a.Unlock()