Method recordTaskEvent

internal/task/manager.go:3742–3781

(
	ctx context.Context,
	taskID string,
	runID string,
	eventType string,
	actor ActorContext,
	payload any,
)

}

func (m *Service) recordTaskEvent(
	ctx context.Context,
	taskID string,
	runID string,
	eventType string,
	actor ActorContext,
	payload any,
) error {
	rawPayload, err := marshalTaskEventPayload(payload)
	if err != nil {
		return err
	}
	event := Event{
		ID:        m.newID("evt"),
		TaskID:    strings.TrimSpace(taskID),
		RunID:     strings.TrimSpace(runID),
		EventType: strings.TrimSpace(eventType),
		Actor:     actor.Actor,
		Origin:    actor.Origin,
		Payload:   rawPayload,
		Timestamp: m.now().UTC(),
	}
	if err := m.store.CreateTaskEvent(ctx, event); err != nil {
		return err
	}

	postCommitCtx := context.Background()
	if ctx != nil {
		postCommitCtx = context.WithoutCancel(ctx)
	}

	record, err := m.store.GetTaskEventRecord(postCommitCtx, event.ID)
	if err != nil {
		m.emitTaskLiveEventBestEffort(postCommitCtx, event.ID)
		return nil
	}
	m.notifyTaskObserverBestEffort(postCommitCtx, record)
	m.emitTaskLiveRecordBestEffort(postCommitCtx, record)
	return nil
}

func (m *Service) notifyTaskObserverBestEffort(ctx context.Context, record EventRecord) {
	if m == nil || m.eventObserver == nil {