We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2111fd3 commit 6b7754aCopy full SHA for 6b7754a
smartsim/_core/mli/infrastructure/storage/backbonefeaturestore.py
@@ -287,6 +287,9 @@ def _broadcast(self) -> int:
287
comm_channel = self._get_comm_channel(descriptor)
288
289
try:
290
+ # todo: given a failure, the message is not sent to any other
291
+ # recipients. consider retrying, adding a dead letter queue, or
292
+ # logging the message details more intentionally
293
comm_channel.send(next_event)
294
num_sent += 1
295
except Exception as ex:
0 commit comments