We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 395a4fb commit f0f03f0Copy full SHA for f0f03f0
router/batchrouter/handle_async.go
@@ -313,6 +313,7 @@ func (brt *Handle) pollAsyncStatus(ctx context.Context) {
313
for {
314
select {
315
case <-ctx.Done():
316
+ brt.logger.Infon("pollAsyncStatus stopped", obskit.DestinationType(brt.destType))
317
return
318
case <-time.After(brt.pollStatusLoopSleep.Load()):
319
brt.configSubscriberMu.RLock()
@@ -390,6 +391,7 @@ func (brt *Handle) asyncUploadWorker(ctx context.Context) {
390
391
392
393
394
+ brt.logger.Infon("asyncUploadWorker stopped", obskit.DestinationType(brt.destType))
395
396
case <-time.After(brt.asyncUploadWorkerTimeout.Load()):
397
0 commit comments