Method reconcileTaskWithStore

internal/task/manager.go:2821–2858

(
	ctx context.Context,
	store DeleteTaskMutationStore,
	taskID string,
)

}

func (m *Service) reconcileTaskWithStore(
	ctx context.Context,
	store DeleteTaskMutationStore,
	taskID string,
) (Task, error) {
	record, err := store.GetTask(ctx, taskID)
	if err != nil {
		return Task{}, err
	}
	dependencies, err := store.ListDependencies(ctx, taskID)
	if err != nil {
		return Task{}, err
	}
	runs, err := store.ListTaskRuns(ctx, RunQuery{TaskID: taskID})
	if err != nil {
		return Task{}, err
	}

	canonicalStatus, err := m.canonicalTaskStatusWithStore(ctx, store, record, dependencies, runs)
	if err != nil {
		return Task{}, err
	}
	if record.Status.Normalize() == canonicalStatus.Normalize() {
		return record, nil
	}

	record.Status = canonicalStatus
	record.UpdatedAt = m.now().UTC()
	if isTerminalTaskStatus(record.Status) {
		record.ClosedAt = record.UpdatedAt
	} else {
		record.ClosedAt = time.Time{}
	}
	if err := store.UpdateTask(ctx, record); err != nil {
		return Task{}, err
	}
	return record, nil
}

func (m *Service) reconcileTaskCascade(ctx context.Context, taskID string) (Task, error) {
	return m.reconcileTaskCascadeWithStore(ctx, m.store, taskID)