     location_change = Map.put(%{}, key, value)
     Proxy.post("events/#{id}", body: %{location: location_change})
     %{body: event} = Proxy.get("events/#{id}")
-    event
+    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
+    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)
+    new_tags = Enum.concat(current_tags, [tag])
     Proxy.post("events/#{id}", body: %{tags: new_tags})
     %{body: event} = Proxy.get("events/#{id}")
-    event
+    event_pipeline(event)
   end
 
   defp duplicate(id) do

    calendar_tags = Enum.filter(event.tags, &String.contains?(&1, "Calendar: "))

    new_tags = Enum.concat(tags, calendar_tags)

    Event.set_tags(event, new_tags)
    new_event = edit_tags_and_fetch(id, new_tags)

    push(socket, "event", %{id: id, event: new_event})


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

  defp send_list_events(socket) do
