diff --git a/lib/tasks/correct_illness_from_csv.rake b/lib/tasks/correct_illness_from_csv.rake
index 65d1106c4..e171d9225 100644
--- a/lib/tasks/correct_illness_from_csv.rake
+++ b/lib/tasks/correct_illness_from_csv.rake
@@ -25,7 +25,7 @@ namespace :correct_illness do
     illness_csv = CSV.parse(file_io, headers: true)
 
     illness_csv.each_with_index do |row, index|
-      next if index < 3
+      next if index < 2
 
       lettings_log_id = row[1]
 
diff --git a/spec/lib/tasks/correct_address_from_csv_spec.rb b/spec/lib/tasks/correct_address_from_csv_spec.rb
index 294ce535b..58bc2e080 100644
--- a/spec/lib/tasks/correct_address_from_csv_spec.rb
+++ b/spec/lib/tasks/correct_address_from_csv_spec.rb
@@ -91,11 +91,11 @@ RSpec.describe "data_import" do
       before do
         allow(storage_service).to receive(:get_file_io)
         .with("addresses_reimport_123.csv")
-        .and_return(replace_entity_ids(lettings_log, lettings_logs[0], lettings_logs[1], lettings_logs[2], File.open("./spec/fixtures/files/addresses_reimport.csv").read))
+        .and_return(StringIO.new(replace_entity_ids(lettings_log, lettings_logs[0], lettings_logs[1], lettings_logs[2], File.open("./spec/fixtures/files/addresses_reimport.csv").read)))
 
         allow(storage_service).to receive(:get_file_io)
         .with("all_addresses_reimport_123.csv")
-        .and_return(replace_entity_ids(lettings_log, lettings_logs[0], lettings_logs[1], lettings_logs[2], File.open("./spec/fixtures/files/addresses_reimport_all_logs.csv").read))
+        .and_return(StringIO.new(replace_entity_ids(lettings_log, lettings_logs[0], lettings_logs[1], lettings_logs[2], File.open("./spec/fixtures/files/addresses_reimport_all_logs.csv").read)))
       end
 
       context "when the file contains issue type column" do
@@ -312,11 +312,11 @@ RSpec.describe "data_import" do
       before do
         allow(storage_service).to receive(:get_file_io)
         .with("addresses_reimport_123.csv")
-        .and_return(replace_entity_ids(sales_log, sales_logs[0], sales_logs[1], sales_logs[2], File.open("./spec/fixtures/files/sales_addresses_reimport.csv").read))
+        .and_return(StringIO.new(replace_entity_ids(sales_log, sales_logs[0], sales_logs[1], sales_logs[2], File.open("./spec/fixtures/files/sales_addresses_reimport.csv").read)))
 
         allow(storage_service).to receive(:get_file_io)
         .with("all_addresses_reimport_123.csv")
-        .and_return(replace_entity_ids(sales_log, sales_logs[0], sales_logs[1], sales_logs[2], File.open("./spec/fixtures/files/sales_addresses_reimport_all_logs.csv").read))
+        .and_return(StringIO.new(replace_entity_ids(sales_log, sales_logs[0], sales_logs[1], sales_logs[2], File.open("./spec/fixtures/files/sales_addresses_reimport_all_logs.csv").read)))
       end
 
       context "when the file contains issue type column" do
diff --git a/spec/lib/tasks/correct_illness_from_csv_spec.rb b/spec/lib/tasks/correct_illness_from_csv_spec.rb
index ef7e82a65..e7b9f3c72 100644
--- a/spec/lib/tasks/correct_illness_from_csv_spec.rb
+++ b/spec/lib/tasks/correct_illness_from_csv_spec.rb
@@ -96,7 +96,7 @@ RSpec.describe "correct_illness" do
       before do
         allow(storage_service).to receive(:get_file_io)
         .with("illness_123.csv")
-        .and_return(replace_entity_ids(lettings_log, second_lettings_log, third_lettings_log, File.open("./spec/fixtures/files/illness_update.csv").read))
+        .and_return(StringIO.new(replace_entity_ids(lettings_log, second_lettings_log, third_lettings_log, File.open("./spec/fixtures/files/illness_update.csv").read)))
       end
 
       it "sets illness to yes and sets correct illness type" do