Skip to content

Commit 4a087fe

Browse files
committed
progress fix for listener service
1 parent dd710f8 commit 4a087fe

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

src/operator/utils/base_listener.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -90,6 +90,10 @@ func NewBaseListener(
9090
log.Printf("[%s] Warning: failed to create progress writer: %v", streamName, err)
9191
progressWriter = nil
9292
} else {
93+
// Write initial progress so the startup probe finds the file immediately
94+
if err := progressWriter.ReportProgress(); err != nil {
95+
log.Printf("[%s] Warning: failed to write initial progress: %v", streamName, err)
96+
}
9397
log.Printf("[%s] Progress writer initialized: %s", streamName, progressFile)
9498
}
9599

0 commit comments

Comments
 (0)