Skip to content

Commit 8505f14

Browse files
committed
less chatty logs
1 parent c875ec0 commit 8505f14

File tree

1 file changed

+0
-4
lines changed

1 file changed

+0
-4
lines changed

dbos/system_database.go

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1857,9 +1857,6 @@ func (s *sysDB) recv(ctx context.Context, input recvInput) (any, error) {
18571857
return false, fmt.Errorf("failed to check message: %w", err)
18581858
}
18591859
if !exists {
1860-
// Wait for notifications using condition variable with timeout pattern
1861-
s.logger.Debug("Waiting for notification on condition variable", "payload", payload)
1862-
18631860
done := make(chan struct{})
18641861
go func() {
18651862
defer cond.L.Unlock()
@@ -1878,7 +1875,6 @@ func (s *sysDB) recv(ctx context.Context, input recvInput) (any, error) {
18781875

18791876
select {
18801877
case <-done:
1881-
s.logger.Debug("Received notification on condition variable", "payload", payload)
18821878
case <-time.After(timeout):
18831879
s.logger.Warn("Recv() timeout reached", "payload", payload, "timeout", input.Timeout)
18841880
case <-ctx.Done():

0 commit comments

Comments
 (0)