Skip to content

Commit 9b40b99

Browse files
committed
Add TODO for placeholders
1 parent f114154 commit 9b40b99

File tree

1 file changed

+2
-0
lines changed
  • quixstreams/dataframe/windows

1 file changed

+2
-0
lines changed

quixstreams/dataframe/windows/base.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -144,6 +144,7 @@ def window_callback(
144144
yield (window, key, window["start"], None)
145145

146146
def heartbeat_callback(timestamp: int) -> Iterable[Message]:
147+
# TODO: Implement heartbeat callback
147148
return []
148149

149150
return self._apply_window(
@@ -196,6 +197,7 @@ def window_callback(
196197
yield (window, key, window["start"], None)
197198

198199
def heartbeat_callback(timestamp: int) -> Iterable[Message]:
200+
# TODO: Implement heartbeat callback
199201
return []
200202

201203
return self._apply_window(

0 commit comments

Comments
 (0)