@@ -333,6 +333,14 @@ func runSubCommand( //nolint: gocyclo,gocognit
 	postgresStartConditions = append(postgresStartConditions, jsonPipe.GetExecutedCondition())
 	exitedConditions = append(exitedConditions, jsonPipe.GetExitedCondition())
 
+	// Give Rewind the same log-pipe readiness conditions, so pg_rewind
+	// never races these readers for the log-destination FIFOs.
+	instance.SetLogPipesReadyCondition(concurrency.MultipleExecuted{
+		postgresLogPipe.GetInitializedCondition(),
+		rawPipe.GetExecutedCondition(),
+		jsonPipe.GetExecutedCondition(),
+	})
+
 	if err := instancestorage.ReconcileWalDirectory(ctx); err != nil {
 		contextLogger.Error(err, "unable to move `pg_wal` directory to the attached volume")
 		return err
 
@@ -201,6 +201,9 @@ type Instance struct {
 	// PgRewindIsRunning tells if there is a `pg_rewind` process running
 	PgRewindIsRunning bool
 
+	// logPipesReady becomes satisfied once the log-destination FIFOs are ready.
+	logPipesReady concurrency.MultipleExecuted
+
 	// canCheckReadiness specifies whether the instance can start being checked for readiness
 	// Is set to true before the instance is run and to false once it exits,
 	// it's used by the readiness probe to know whether it should be short-circuited
@@ -306,6 +309,12 @@ func (instance *Instance) SetCanCheckReadiness(enabled bool) {
 	instance.canCheckReadiness.Store(enabled)
 }
 
+// SetLogPipesReadyCondition records the conditions that indicate when the log-destination
+// FIFOs are ready. PGRewind waits on this condition as pg_rewind invokes restore_command.
+func (instance *Instance) SetLogPipesReadyCondition(conditions concurrency.MultipleExecuted) {
+	instance.logPipesReady = conditions
+}
+
 // GetClusterOrDefault returns the cached cluster, or an empty cluster if not set.
 // The empty cluster provides safe defaults via getter methods.
 func (instance *Instance) GetClusterOrDefault() *apiv1.Cluster {
@@ -1266,6 +1275,10 @@ func pgRewindShouldRetry(ctx context.Context, _ error) bool {
 func (instance *Instance) Rewind(ctx context.Context) error {
 	contextLogger := log.FromContext(ctx)
 
+	// pg_rewind invokes restore_command, wait for the log-destination FIFOs
+	// to be ready first here.
+	instance.logPipesReady.Wait()
+
 	// Signal the liveness probe that we are running pg_rewind before starting postgres
 	instance.PgRewindIsRunning = true
 	defer func() {