 
   defp async_rsvp_count_fetch(event) do
     Task.async(fn ->
-      id = event.identifiers |> List.first() |> String.split(":") |> List.last()
-      %{body: %{count: num_rsvps}} = Proxy.get("events/#{id}/rsvp-count")
-      Map.put(event, :attendance_count, num_rsvps)
+      try do
+        id = event.identifiers |> List.first() |> String.split(":") |> List.last()
+        %{body: %{count: num_rsvps}} = Proxy.get("events/#{id}/rsvp-count")
+        Map.put(event, :attendance_count, num_rsvps)
+      rescue
+        _e -> Map.put(event, :attendance_count, 0)
+      end
     end)
   end
 end


  defp send_esm_events(socket) do
    Proxy.stream("events")
    |> Stream.map(&async_rsvp_count_fetch/1)
    |> Stream.map(&Task.await/1)
    |> Stream.map(&event_pipeline/1)
    |> Stream.each(fn event ->
         id = event.identifiers |> List.first() |> String.split(":") |> List.last()
         push(socket, "event", %{id: id, event: event})
       end)
    |> Stream.run()
  end

  defp send_list_events(socket) do

    location_change = Map.put(%{}, key, value)
    Proxy.post("events/#{id}", body: %{location: location_change})
    %{body: event} = Proxy.get("events/#{id}")
    event_pipeline(event)
  end

  def edit_tags_and_fetch(id, tags) do
    Proxy.post("events/#{id}", body: %{tags: tags})
    %{body: event} = Proxy.get("events/#{id}")
    event_pipeline(event)
  end

  defp set_status(id, status) do
    Proxy.post("events/#{id}", body: %{status: status})
    %{body: event} = Proxy.get("events/#{id}")
    event_pipeline(event)
  end

  defp mark_action(id, action) do
    %{body: %{tags: current_tags}} = Proxy.get("events/#{id}")
    tag = "Event: Action: #{String.capitalize(action)}"
    new_tags = Enum.concat(current_tags, [tag])
    Proxy.post("events/#{id}", body: %{tags: new_tags})
    %{body: event} = Proxy.get("events/#{id}")
    event_pipeline(event)
  end

  defp duplicate(id) do
