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 e9d8ef3 commit 43a4900Copy full SHA for 43a4900
zulip/integrations/zephyr/check-mirroring
@@ -300,6 +300,11 @@ if "error" in res["result"]:
300
logging.error(res["msg"])
301
print_status_and_exit(1)
302
messages = [event["message"] for event in res["events"]]
303
+for m in messages:
304
+ if m.get("stream_id") is None:
305
+ # Non-stream messages can't have a retention policy, so clean
306
+ # them up so they don't pile up
307
+ zulip_client.delete_message(m["id"])
308
logger.info("Finished receiving Zulip messages!")
309
310
receive_zephyrs()
0 commit comments