Skip to content

Commit bbcccde

Browse files
authored
Remove the window expiration logs (#945)
These logs are noisy, and they don't have enough metadata to be useful for the end users.
1 parent acb49fa commit bbcccde

File tree

1 file changed

+0
-19
lines changed

1 file changed

+0
-19
lines changed

quixstreams/dataframe/windows/time_based.py

Lines changed: 0 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,4 @@
11
import logging
2-
import time
32
from enum import Enum
43
from typing import TYPE_CHECKING, Any, Iterable, Literal, Optional
54

@@ -207,9 +206,6 @@ def expire_by_partition(
207206
max_expired_end: int,
208207
collect: bool,
209208
) -> Iterable[WindowKeyResult]:
210-
start = time.monotonic()
211-
count = 0
212-
213209
for (
214210
window_start,
215211
window_end,
@@ -219,39 +215,24 @@ def expire_by_partition(
219215
collect=collect,
220216
delete=True,
221217
):
222-
count += 1
223218
yield key, self._results(aggregated, collected, window_start, window_end)
224219

225-
if count:
226-
logger.debug(
227-
"Expired %s windows in %ss", count, round(time.monotonic() - start, 2)
228-
)
229-
230220
def expire_by_key(
231221
self,
232222
key: Any,
233223
state: WindowedState,
234224
max_expired_start: int,
235225
collect: bool,
236226
) -> Iterable[WindowKeyResult]:
237-
start = time.monotonic()
238-
count = 0
239-
240227
for (
241228
window_start,
242229
window_end,
243230
), aggregated, collected, _ in state.expire_windows(
244231
max_start_time=max_expired_start,
245232
collect=collect,
246233
):
247-
count += 1
248234
yield (key, self._results(aggregated, collected, window_start, window_end))
249235

250-
if count:
251-
logger.debug(
252-
"Expired %s windows in %ss", count, round(time.monotonic() - start, 2)
253-
)
254-
255236
def _on_expired_window(
256237
self,
257238
value: Any,

0 commit comments

Comments
 (0)