Skip to content

Commit

Permalink
mix format
Browse files Browse the repository at this point in the history
  • Loading branch information
josevalim committed Jan 6, 2023
1 parent d3b6a43 commit 24e03c9
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions lib/flow/materialize.ex
Original file line number Diff line number Diff line change
Expand Up @@ -164,8 +164,7 @@ defmodule Flow.Materialize do
partitions = Enum.to_list(0..(stages - 1))

{producers, consumers,
departition_ops(acc, fun, trigger, partitions, acc_fun, merge_fun, done_fun),
window}
departition_ops(acc, fun, trigger, partitions, acc_fun, merge_fun, done_fun), window}
end

defp start_producers({:flows, flows}, ops, start_link, window, options, dispatcher) do
Expand Down

0 comments on commit 24e03c9

Please sign in to comment.