Skip to content

Commit d421e90

Browse files
committed
storage: log when we skip rendering and ingestion
1 parent ba65858 commit d421e90

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

src/storage/src/storage_state.rs

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -790,6 +790,14 @@ impl<'w, A: Allocate> Worker<'w, A> {
790790
// management being a bit of a mess. we should clean this up and remove weird if
791791
// statements like this.
792792
if resume_uppers.values().all(|frontier| frontier.is_empty()) || as_of.is_empty() {
793+
tracing::info!(
794+
?resume_uppers,
795+
?as_of,
796+
"worker {}/{} skipping building ingestion dataflow \
797+
for {ingestion_id} because the ingestion is finished",
798+
self.timely_worker.index(),
799+
self.timely_worker.peers(),
800+
);
793801
return;
794802
}
795803

0 commit comments

Comments
 (0)