diff --git a/email-worker/worker.py b/email-worker/worker.py index 458c991..6f20280 100644 --- a/email-worker/worker.py +++ b/email-worker/worker.py @@ -142,6 +142,11 @@ class MessageProcessor: self.metrics.increment_bounce(domain, 'rewritten') else: from_addr_final = from_addr + + # ⭐ HIER NEU: Marker für alle Emails von extern setzen + if not skip_rules: # Nur wenn nicht bereits processed + parsed['X-SES-Worker-Processed'] = 'delivered' + raw_bytes = parsed.as_bytes() except Exception as e: log(f"⚠ Parsing/Logic Error: {e}. Sending original.", 'WARNING', worker_name)