adding extra in put for byte code

Author: reanbrenda

api/data_ingestion/internal/email.py

@@ -149,7 +149,7 @@ def send_dq_report_email_with_pdf(body: EmailRenderRequest[DqReportRenderRequest
 
     # Generate HTML and text content
     res = requests.post(
-        f"{settings.EMAIL_RENDERER_URL}/email/dq-report",
+        f"{settings.EMAIL_RENDERER_SERVICE_URL}/email/dq-report",
         headers={
             "Authorization": f"Bearer {settings.EMAIL_RENDERER_BEARER_TOKEN}",
             "Content-Type": "application/json",
@@ -169,7 +169,7 @@ def send_dq_report_email_with_pdf(body: EmailRenderRequest[DqReportRenderRequest
 
     # Generate PDF
     pdf_res = requests.post(
-        f"{settings.EMAIL_RENDERER_URL}/email/dq-report-pdf",
+        f"{settings.EMAIL_RENDERER_SERVICE_URL}/email/dq-report-pdf",
         headers={
             "Authorization": f"Bearer {settings.EMAIL_RENDERER_BEARER_TOKEN}",
             "Content-Type": "application/json",
@@ -217,7 +217,7 @@ async def generate_dq_report_pdf(body: EmailRenderRequest[DqReportRenderRequest]
 
     # Call the email service to generate PDF
     res = requests.post(
-        f"{settings.EMAIL_RENDERER_URL}/email/dq-report-pdf",
+        f"{settings.EMAIL_RENDERER_SERVICE_URL}/email/dq-report-pdf",
         headers={
             "Authorization": f"Bearer {settings.EMAIL_RENDERER_BEARER_TOKEN}",
             "Content-Type": "application/json",

api/data_ingestion/routers/email.py

@@ -154,4 +154,26 @@ def send_generic_email(
     if credentials.credentials != settings.EMAIL_RENDERER_BEARER_TOKEN:
         raise HTTPException(status_code=status.HTTP_401_UNAUTHORIZED)
 
-    send_email_base(**body.model_dump())
+    # Ensure attachments are base64-encoded strings as required by Mailjet v3 send API
+    email_data = body.model_dump()
+    if email_data.get("attachments"):
+        import base64
+
+        normalized_attachments = []
+        for attachment in email_data["attachments"]:
+            normalized = attachment.copy()
+            content = normalized.get("content")
+            # If content is bytes, encode to base64 string
+            if isinstance(content, bytes | bytearray):
+                normalized["content"] = base64.b64encode(content).decode("ascii")
+            # If content is a data URL (e.g., data:application/pdf;base64,XXX), strip the prefix
+            elif isinstance(content, str) and content.startswith("data:"):
+                try:
+                    normalized["content"] = content.split(",", 1)[1]
+                except Exception:
+                    pass
+            # Otherwise assume it's already base64 string; leave as is
+            normalized_attachments.append(normalized)
+        email_data["attachments"] = normalized_attachments
+
+    send_email_base(**email_data)

api/data_ingestion/schemas/email.py

@@ -48,3 +48,4 @@ class GenericEmailRequest(BaseModel):
     subject: str
     html_part: str | None = Field(None)
     text_part: str | None = Field(None)
+    attachments: list[dict] | None = Field(None)