MCPcopy
hub / github.com/faust-streaming/faust / sync_from_storage

Method sync_from_storage

faust/tables/objects.py:126–129  ·  view source on GitHub ↗

Sync set contents from storage.

(self)

Source from the content-addressed store, hash-verified

124 self.sync_from_storage()
125
126 def sync_from_storage(self) -> None:
127 """Sync set contents from storage."""
128 for key, value in self.storage.items():
129 self[key].sync_from_storage(value)
130
131 def reset_state(self) -> None:
132 """Reset table local state."""

Callers 1

on_recovery_completedMethod · 0.95

Calls 2

itemsMethod · 0.45
sync_from_storageMethod · 0.45

Tested by

no test coverage detected