go fmt
This commit is contained in:
@@ -392,7 +392,6 @@ func (a *Agent) processUserInputs(job *types.Job, role string, conv Messages) Me
|
|||||||
|
|
||||||
func (a *Agent) consumeJob(job *types.Job, role string) {
|
func (a *Agent) consumeJob(job *types.Job, role string) {
|
||||||
|
|
||||||
|
|
||||||
if err := job.GetContext().Err(); err != nil {
|
if err := job.GetContext().Err(); err != nil {
|
||||||
job.Result.Finish(fmt.Errorf("expired"))
|
job.Result.Finish(fmt.Errorf("expired"))
|
||||||
return
|
return
|
||||||
|
|||||||
Reference in New Issue
Block a user