Logger.info("Processing #{book.title} (#{book.author})")

    |> Task.async_stream(fn p -> process_paragraph(p, book_id) end,
      timeout: :infinity
    )

    |> Stream.map(fn p -> process_paragraph(p, book_id) end)

    Logger.info("Processed #{book.title} (#{book.author})")

        %{title: title, author: author}

        %{title: title, author: author},
        timeout: 25000

  timeout: 60000

  timeout: 120_000,
  queue_target: 1500,
  queue_interval: 5000