Skip to content

Commit 991f309

Browse files
committed
Fix wrong call to serialize frame
1 parent 1b35e2b commit 991f309

File tree

2 files changed

+7
-5
lines changed

2 files changed

+7
-5
lines changed

rqd/rqd/rqcore.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -203,7 +203,7 @@ def backupCache(self):
203203
return
204204
with open(self.backup_cache_path, "wb") as f:
205205
for item in list(self.__cache.values()):
206-
serialized = item.SerializeToString()
206+
serialized = item.runFrame.SerializeToString()
207207
f.write(len(serialized).to_bytes(4, byteorder="big"))
208208
f.write(serialized)
209209

rqd/tests/rqcore_test.py

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -598,9 +598,10 @@ def test_backupCache_withPath(self, mockOpen):
598598
"""Test backupCache writes frame data when backup path is configured"""
599599
self.rqcore.backup_cache_path = '/tmp/rqd/cache.dat'
600600
frameId = 'frame123'
601-
runFrame = mock.MagicMock()
602-
runFrame.SerializeToString.return_value = b'serialized_frame_data'
603-
self.rqcore.storeFrame(frameId, runFrame)
601+
runningFrame = mock.MagicMock()
602+
runningFrame.runFrame = mock.MagicMock()
603+
runningFrame.runFrame.SerializeToString.return_value = b'serialized_frame_data'
604+
self.rqcore.storeFrame(frameId, runningFrame)
604605

605606
self.rqcore.backupCache()
606607

@@ -663,7 +664,8 @@ def test_recoverCache_validBackup(self):
663664
frame_id = frameId,
664665
frame_name = "frame_name"
665666
)
666-
self.rqcore.storeFrame(frameId, frame)
667+
running_frame = rqd.rqnetwork.RunningFrame(self.rqcore, frame)
668+
self.rqcore.storeFrame(frameId, running_frame)
667669
self.rqcore.backupCache()
668670
self.__cache = {}
669671
self.rqcore.recoverCache()

0 commit comments

Comments
 (0)