Skip to content

Commit 0d86f65

Browse files
wip
1 parent 1bdf835 commit 0d86f65

File tree

2 files changed

+39
-37
lines changed

2 files changed

+39
-37
lines changed

src/execution_plans/stage.rs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -511,13 +511,15 @@ impl DisplayAs for StageExec {
511511
}
512512
Some(display_ctx) => {
513513
for (i, _) in self.tasks.iter().enumerate() {
514+
let mut extra_spacing = "".to_string();
514515
if i > 0 {
515-
writeln!(f)?;
516+
writeln!(f)?; // Add newline for each task
517+
extra_spacing = " ".repeat(self.depth); // with_indent() in DisplayableExectutionPlan will not add indentation for tasks, so we add it manually.
516518
}
517519
writeln!(
518520
f,
519521
"{}{}{}{} {}",
520-
" ".repeat(self.depth),
522+
extra_spacing,
521523
LTCORNER,
522524
HORIZONTAL.repeat(5),
523525
format!(" {} ", self.name),

0 commit comments

Comments
 (0)