Function checkTaskDrift

backend/runner/taskrun/running_scheduler.go:273–285

checkTaskDrift performs the actual drift comparison logic. Returns nil if no drift, or an error describing the drift.

(task *store.TaskMessage, database *store.DatabaseMessage, plan *store.PlanMessage)

// checkTaskDrift performs the actual drift comparison logic.
// Returns nil if no drift, or an error describing the drift.
func checkTaskDrift(task *store.TaskMessage, database *store.DatabaseMessage, plan *store.PlanMessage) error {
	// Check project drift.
	if database.ProjectID != plan.ProjectID {
		return errors.Errorf("target database belongs to project %q, but plan belongs to project %q", database.ProjectID, plan.ProjectID)
	}

	// Check environment drift.
	if task.Environment != "" && database.EffectiveEnvironmentID != nil && *database.EffectiveEnvironmentID != task.Environment {
		return errors.Errorf("target database is in environment %q, but task expected environment %q", *database.EffectiveEnvironmentID, task.Environment)
	}

	return nil
}

// isSequentialTask returns whether the task should be executed sequentially.
// Only release-based DATABASE_MIGRATE tasks are sequential to ensure ordered