I have the following code Repo.transaction(fn -> Blog |> where(title: ^title) |> Repo.stream() |> Flow.from_enumerable() |> Flow.each(fn x -> IO.inspect x end) |> Flow.run() end) When I run this, I get the error: (RuntimeError) cannot reduce stream outside of transaction Is Ecto and Flow not supp…

I believe the stream must be used in the same process that created the transaction. There was some work towards GenStage integration in Ecto: https://github.com/elixir-ecto/ecto/pull/2028 but it’s been closed.

Elixir Programming Language Forum

Repo.stream + Flow.from_enumerable

Questions / Help

apr September 10, 2018, 11:21pm 3

Darn. Oh well. Guess I need to use Task.async_stream