diff --git a/tubesync/sync/tasks.py b/tubesync/sync/tasks.py
index c1194d52..cd4ec7ae 100644
--- a/tubesync/sync/tasks.py
+++ b/tubesync/sync/tasks.py
@@ -766,7 +766,7 @@ def wait_for_media_premiere(media_id):
         media.save()
 
 @background(schedule=90, remove_existing_tasks=False)
-def delete_all_media_for_source(source_id, source_name, source_directory_path):
+def delete_all_media_for_source(source_id, source_name, source_directory):
     source = None
     try:
         source = Source.objects.get(pk=source_id)
@@ -786,7 +786,7 @@ def delete_all_media_for_source(source_id, source_name, source_directory_path):
             with atomic():
                 media.delete()
     # Remove the directory, if the user requested that
-    directory_path = Path(source_directory_path)
+    directory_path = Path(source_directory)
     if (directory_path / '.to_be_removed').is_file():
         log.info(f'Deleting directory for: {source_name}: {directory_path}')
         rmtree(directory_path, True)