diff --git a/00-Sort_BI_Extracts.py b/00-Sort_BI_Extracts.py
deleted file mode 100644
index 52bdb4d3d..000000000
--- a/00-Sort_BI_Extracts.py
+++ /dev/null
@@ -1,85 +0,0 @@
-import os
-from collections import defaultdict
-import re
-import gzip
-
-if __name__ == "__main__":
-    compress_files = False
-
-    base_dir = r"\\stats\sourcedev\Source_Linkage_File_Updates\Extracts Temp"
-
-    print("Looking in '{}' for csv files.".format(base_dir))
-
-    # Create a list of all the csv files
-    all_extracts = [file for file in os.listdir(base_dir) if file.endswith(".csv")]
-
-    # Set up a default dict
-    files_by_year = defaultdict(list)
-
-    # Set up the regEx
-    # Look for files ending "-20...."
-    pattern = re.compile(r"-20(\d\d\d\d).csv")
-
-    # Create a dictionary as {'Year':[file1, file2]} etc.
-    # match.group(1) will be the year e.g. 1718
-    for file in all_extracts:
-        match = pattern.search(file)
-        if match:
-            files_by_year[match.group(1)].append(file)
-
-    n_files = files_by_year.__len__()
-
-    if n_files == 0:
-        print("No correctly named csv files found.")
-    else:
-        print("Found {} csv files to process.".format(n_files))
-
-    # Loop through the dictionary by year
-    for year in files_by_year.keys():
-        # Create a string for the relevant year's directory
-        year_dir = os.path.join(
-            r"\\stats\sourcedev\Source_Linkage_File_Updates\{}\Extracts".format(year)
-        )
-
-        # First check if the year folder exists
-        # if not create it
-        if os.path.exists(year_dir) != True:
-            os.makedirs(year_dir)
-            print("Creating new folder for {}".format(year))
-
-        for file in files_by_year[year]:
-            # Create string for the 'old' and 'new' locations
-            unsorted_file = os.path.join(base_dir, file)
-            sorted_file = os.path.join(year_dir, file)
-
-            # If a file already exists remove the old one first
-            if os.path.exists(sorted_file):
-                try:
-                    os.remove(sorted_file)
-                except PermissionError:
-                    print(
-                        "Tried to remove {} from the {} Extracts folder but couldn't.\nCheck if the file is open then re-run this script.".format(
-                            file, year
-                        )
-                    )
-                else:
-                    print(
-                        "Removed the existing {} from the {} Extracts folder.".format(
-                            file, year
-                        )
-                    )
-
-            # Move to the sorted location
-            os.rename(unsorted_file, sorted_file)
-            print("Moved {} to the {} Extracts folder.".format(file, year))
-
-            if compress_files:
-                with open(sorted_file, "rb") as uncompressed_csv:
-                    with gzip.open(sorted_file + ".gz", "wb") as gzip_csv:
-                        print("Compressing {} ...".format(file))
-                        gzip_csv.writelines(uncompressed_csv)
-                os.remove(sorted_file)
-
-    input(
-        "\n---------------------------------------------\nThe script has finished, press enter to exit."
-    )
diff --git a/00_Sort_BI_Extracts.R b/00_Sort_BI_Extracts.R
new file mode 100644
index 000000000..888ede5b2
--- /dev/null
+++ b/00_Sort_BI_Extracts.R
@@ -0,0 +1,50 @@
+# Define the source directory and financial year pattern
+compress_files <- FALSE
+source_dir <- "/conf/sourcedev/Source_Linkage_File_Updates/Extracts Temp"
+pattern <- "-20(\\d{4})\\.csv"
+
+
+# List all the CSV files in the source directory
+cat(stringr::str_glue("Looking in '{source_dir}' for csv files."))
+csv_files <- list.files(source_dir, pattern = ".csv", full.names = TRUE)
+print(stringr::str_glue("Found {length(csv_files)} csv files to process."))
+
+# Create a function to extract the financial year from a filename
+extract_financial_year <- function(filename) {
+  match <- regexpr(pattern, basename(filename))
+  if (match[[1]][1] > 0) {
+    financial_year <- substr(basename(filename), match[[1]][1] + 3, match[[1]][1] + 6)
+    return(financial_year)
+  } else {
+    return(NULL)
+  }
+}
+
+# Create directories for each financial year and move files
+for (csv_file in csv_files) {
+  financial_year <- extract_financial_year(csv_file)
+  # check if year directory exists
+  if (!is.null(financial_year)) {
+    financial_year_dir <- file.path("/conf/sourcedev/Source_Linkage_File_Updates", financial_year, "Extracts")
+    # if not, create the year directory
+    if (!dir.exists(financial_year_dir)) {
+      dir.create(financial_year_dir)
+    }
+
+    # compress file
+    if (compress_files) {
+      cat("Compressing:", basename(csv_file), "\n")
+      system2(
+        command = "gzip",
+        args = shQuote(csv_file)
+      )
+      csv_file <- paste0(csv_file, ".gz")
+    }
+
+    # move file
+    new_file_path <- file.path(financial_year_dir, basename(csv_file))
+    file.copy(csv_file, new_file_path)
+    file.remove(csv_file)
+    cat("Moved:", csv_file, "to", new_file_path, "\n")
+  }
+}