Skip to content

Commit

Permalink
docs
Browse files Browse the repository at this point in the history
  • Loading branch information
kwannoel committed Nov 3, 2023
1 parent 4d487f0 commit 54bd7b6
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions src/meta/src/barrier/progress.rs
Original file line number Diff line number Diff line change
Expand Up @@ -159,8 +159,11 @@ impl TrackingJob {
}
}

/// Returns whether the `TrackingJob` requires a checkpoint to complete.
pub(crate) fn is_checkpoint(&self) -> bool {
match self {
// Recovered tracking job is always a streaming job,
// It requires a checkpoint to complete.
TrackingJob::Recovered(_) => true,
TrackingJob::New(command) => {
command.context.kind.is_initial() || command.context.kind.is_checkpoint()
Expand Down

0 comments on commit 54bd7b6

Please sign in to comment.