| 166 | } |
| 167 | |
| 168 | func logPending(ctx context.Context, el EventLog, execID string, start *proto.AgentStart) error { |
| 169 | return el.AppendExec(ctx, &proto.ExecutionEvent{ |
| 170 | Timestamp: timestamppb.Now(), |
| 171 | ExecId: execID, |
| 172 | AgentId: start.AgentId, |
| 173 | AgentConfig: start.AgentConfig, |
| 174 | Inputs: start.Messages, |
| 175 | State: proto.State_STATE_PENDING, |
| 176 | }) |
| 177 | } |
| 178 | |
| 179 | func logFailed(ctx context.Context, el EventLog, execID string, start *proto.AgentStart) error { |
| 180 | return el.AppendExec(ctx, &proto.ExecutionEvent{ |