Skip to content

Commit 22c9160

Browse files
committed
fix(pipeline): restore analyzer invariant error messages for backward compat
1 parent 8727044 commit 22c9160

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

datafusion/optimizer/src/logical_pipeline/sync_phase.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -131,7 +131,7 @@ impl SyncAnalysisPhase {
131131
}
132132

133133
plan.check_invariants(InvariantLevel::Always)
134-
.map_err(|e| e.context("Invalid input plan passed to analysis phase"))?;
134+
.map_err(|e| e.context("Invalid input plan passed to Analyzer"))?;
135135

136136
let passes = match &self.strategy {
137137
Strategy::Once => 1,
@@ -168,7 +168,7 @@ impl SyncAnalysisPhase {
168168
}
169169

170170
plan.check_invariants(InvariantLevel::Executable)
171-
.map_err(|e| e.context("Invalid plan after analysis phase"))?;
171+
.map_err(|e| e.context("Invalid (non-executable) plan after Analyzer"))?;
172172

173173
Ok(plan)
174174
}
@@ -185,7 +185,7 @@ impl SyncAnalysisPhase {
185185
}
186186

187187
plan.check_invariants(InvariantLevel::Always)
188-
.map_err(|e| e.context("Invalid input plan passed to analysis phase"))?;
188+
.map_err(|e| e.context("Invalid input plan passed to Analyzer"))?;
189189

190190
let passes = match &self.strategy {
191191
Strategy::Once => 1,
@@ -224,7 +224,7 @@ impl SyncAnalysisPhase {
224224
}
225225

226226
plan.check_invariants(InvariantLevel::Executable)
227-
.map_err(|e| e.context("Invalid plan after analysis phase"))?;
227+
.map_err(|e| e.context("Invalid (non-executable) plan after Analyzer"))?;
228228

229229
Ok(plan)
230230
}

0 commit comments

Comments
 (0)