|> Task.async_stream(Esperantisto.Saver, :start, [], timeout: 30000)

    |> Task.async_stream(Esperantisto.Saver, :start, [], timeout: 60000)

  def sentence_to_words(sentence) do
    sentence
    |> String.split()
    |> Stream.map(fn w -> String.replace(w, [".", ","], "") end)
    |> Stream.map(&String.downcase/1)
  end

    DB.save_sentence(acc.book_id, sentence)

    sentence_id = DB.save_sentence(acc.book_id, sentence)
    sentence
    |> Esperantisto.Text.sentence_to_words()
    |> Task.async_stream(fn word -> DB.save_word(sentence_id, word) end, timeout: 30000, max_concurrency: 10)
    |> Stream.run
   

    Bolt.Sips.query!(

    result = Bolt.Sips.query!(

      MERGE (book) -[:HAVE_SENTENCE]-> (sentence:Sentence {text: $sentence})
      RETURN sentence

      MERGE (book) -[:HAS_SENTENCE]-> (sentence:Sentence {text: $sentence})
      RETURN id(sentence) as sentence_id

    [id] = result["sentence_id"]
    id

  def save_word(sentence_id, word) do
    Bolt.Sips.query!(
      Bolt.Sips.conn(),
      """
      MATCH (sentence)
      WHERE id(sentence) = $id
      WITH sentence
      MERGE (word:Word {word: $word})
      MERGE (word) -[:OF_SENTENCE]-> (sentence)
      """,
      %{id: sentence_id, word: word},
      timeout: 25000
    )
  end