(ctx context.Context, el EventLog, execID string, start *proto.AgentStart)
| 186 | } |
| 187 | |
| 188 | func logCompleted(ctx context.Context, el EventLog, execID string, start *proto.AgentStart) error { |
| 189 | return el.AppendExec(ctx, &proto.ExecutionEvent{ |
| 190 | Timestamp: timestamppb.Now(), |
| 191 | ExecId: execID, |
| 192 | AgentId: start.AgentId, |
| 193 | State: proto.State_STATE_COMPLETED, |
| 194 | }) |
| 195 | } |
| 196 | |
| 197 | func logOutputs(ctx context.Context, el EventLog, execID string, start *proto.AgentStart, outputs []*proto.Message) error { |
| 198 | return el.AppendExec(ctx, &proto.ExecutionEvent{ |