     write_header_row
     metadata_file_path
     |> File.stream!
-    |> CSVParser.parse_stream(headers: false)
+    |> DefaultCSVParser.parse_stream(headers: false)
     |> Stream.map(&(process_metadata_row(&1, datafiles_path)))
     |> Stream.map(&FileProcessor.process/1)
     |> Stream.filter(fn ({:ok,_}) -> true; (_) -> false end)
     |> Stream.flat_map(&prepare_file_for_csv/1)
     |> Stream.with_index(1)
     |> Stream.flat_map(&prepare_row_for_csv/1)
-    |> CSVParser.dump_to_stream
+    |> DefaultCSVParser.dump_to_stream
     |> Enum.into(File.stream!("processed_data.csv", [:delayed_write, :append]))
   end
 

defmodule DataSanitiser do
  NimbleCSV.define(CSVParser, separator: ",", escape: "\"")

  alias DataSanitiser.FileProcessor
  alias DataSanitiser.FileMetadata

      "Original File",
      "Original Row"
    ]]
    |> DefaultCSVParser.dump_to_stream
    |> Enum.into(File.stream!("processed_data.csv", [:delayed_write]))
  end

