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}

    )