import wmill
def main(record: dict):
message = {
"channel": "email",
"received_at": record.get("received_at"),
"subject": record.get("subject", ""),
"sender": record.get("sender", ""),
"body_text": record.get("body_text", ""),
"attachments": []
}
return wmill.run_script_by_path(
"u/AlexandrosKoronakis/TARMA-run_inbound_intake_pipeline",
args={"message": message}
)Submitted by akoronakis660 44 days ago