Skip to content

Commit 0cb995b

Browse files
committed
✨ feat(app): update receiver client methods
- Adjusted indentation for parameters in methods - Fixed logic for task snapshot credential processing
1 parent 591eb41 commit 0cb995b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

app/receiver/receiver_client.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -367,7 +367,7 @@ async def on_message(self, message: AbstractIncomingMessage):
367367
data = snap_data.data
368368
renew_snap_data = []
369369
for task in data:
370-
if not task.snapshot_credential:
370+
if not task.snapshot_credential and not task.processed:
371371
try:
372372
await Task.create_and_send(
373373
queue_name=task.channel, task=task.snapshot_data

0 commit comments

Comments
 (0)