whichdan

  Users.all()
  |> Enum.filter(&Users.is_expired?(&1, Date.utc_today()))
  |> Enum.map(&generate_expiry_email/1)
  |> tap(&IO.inspect(label: "Expiry Email"))
  |> Enum.reject(&is_nil/1)
  |> bulk_send()

  .map(g => { return { key: g.key, rows: g.rows.map(r => r[1]) }})

  .map(g => ({ key: g.key, rows: g.rows.map(r => r[1]) }))