diff --git a/app/receiver/receiver_client.py b/app/receiver/receiver_client.py
index 106721bce..64827d18a 100644
--- a/app/receiver/receiver_client.py
+++ b/app/receiver/receiver_client.py
@@ -367,7 +367,7 @@ async def on_message(self, message: AbstractIncomingMessage):
                 data = snap_data.data
                 renew_snap_data = []
                 for task in data:
-                    if not task.snapshot_credential:
+                    if not task.snapshot_credential and not task.processed:
                         try:
                             await Task.create_and_send(
                                 queue_name=task.channel, task=task.snapshot_data