diff --git a/server/tes.go b/server/tes.go index 1b95291b1..3d45558a2 100644 --- a/server/tes.go +++ b/server/tes.go @@ -43,7 +43,12 @@ func (ts *TaskService) CreateTask(ctx context.Context, task *tes.Task) (*tes.Cre } // dispatch to compute backend - go ts.Compute.WriteEvent(ctx, events.NewTaskCreated(task)) + go func() { + err := ts.Compute.WriteEvent(ctx, events.NewTaskCreated(task)) + if err != nil { + ts.Log.Error("error submitting task to compute backend", "taskID", task.Id, "error", err) + } + }() return &tes.CreateTaskResponse{Id: task.Id}, nil }