|> Task.async_stream(fn word -> DB.save_word(sentence_id, word) end,

    |> Task.async_stream(
      fn word ->
        DB.save_word(sentence_id, word)
        word
      end,
      timeout: 30000,
      max_concurrency: 10
    )
    |> Stream.map(fn {:ok, v} -> v end)
    |> Stream.scan(
      {nil, nil},
      fn word, {_, prev} -> {prev, word} end
    )
    |> Task.async_stream(
      fn {prev, word} ->
        DB.save_word_order(prev, word)
      end,

  end
  def save_word_order({prev_1, prev_2}, next) do
    save_word_order(prev_1, next)
    save_word_order(prev_2, next)

  def save_word_order(prev, {next_1, next_2}) do
    save_word_order(prev, next_1)
    save_word_order(prev, next_2)
  end
  def save_word_order({prev_1, prev_2}, {_next_1, _next_2} = next) do
    save_word_order(prev_1, next)
    save_word_order(prev_2, next)
  end
  def save_word_order(prev, next) do
    Bolt.Sips.query!(
      Bolt.Sips.conn(),
      """
      MATCH (prev:Word {word: $prev})
      MATCH (next:Word {word: $next})
      MERGE (prev) -[:PREVIOUS_OF]-> (next)
      MERGE (next) -[:NEXT_TO]-> (prev)
      """,
      %{prev: prev, next: next},
      timeout: 25000
    )
  end