update eventcounts
use QuickAlias, MyAppWeb
use QuickAlias, MyAppBe
use QuickAlias, MyApp
require Ecto.Query
require Ash.QuerySection
Location.get_rows_as_stream()
|> Stream.map(&Location.update_eventcount/1)
|> Stream.take(1_000_000)
|> Stream.run():okAgent.get_rows_as_stream()
|> Stream.map(&Agent.update_eventcount/1)
|> Stream.take(1_000_000)
|> Stream.run():ok
