Skip to content

Commit b3767a3

Browse files
committed
__slot__ on run and runserial (untested)
1 parent 0cf7eba commit b3767a3

File tree

3 files changed

+4
-2
lines changed

3 files changed

+4
-2
lines changed

bobocep/cep/engine/decider/run.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,8 @@ class BoboRun:
3232
A run that tracks the progress of a partially completed complex event.
3333
"""
3434

35+
__slots__ = ("_lock", "_run_id", "_phenomenon_name", "_pattern",
36+
"_block_index", "_history", "_halted")
3537
def __init__(self,
3638
run_id: str,
3739
phenomenon_name: str,

bobocep/cep/engine/decider/runserial.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,8 @@ class BoboRunSerial(BoboJSONable):
3535
BLOCK_INDEX = "block_index"
3636
HISTORY = "history"
3737

38+
__slots__ = ("_run_id", "_phenomenon_name", "_pattern_name",
39+
"_block_index", "_history")
3840
def __init__(self,
3941
run_id: str,
4042
phenomenon_name: str,

tests/test_bobocep/test_cep/test_engine/test_receiver/test_BoboReceiver.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -139,7 +139,5 @@ def test_invalid_data_reject(self):
139139

140140
assert receiver.size() == 0
141141
receiver.add_data(data=123)
142-
assert receiver.size() == 1
143-
receiver.update()
144142
assert receiver.size() == 0
145143
assert len(subscriber.output) == 0

0 commit comments

Comments
 (0)