diff --git a/Infrastructure/MassTransit/Activities/Files/UploadFileToBucketActivity.cs b/Infrastructure/MassTransit/Activities/Files/UploadFileToBucketActivity.cs
index 62356ae..4f20d49 100644
--- a/Infrastructure/MassTransit/Activities/Files/UploadFileToBucketActivity.cs
+++ b/Infrastructure/MassTransit/Activities/Files/UploadFileToBucketActivity.cs
@@ -30,9 +30,13 @@ namespace Musify.Infrastructure.MassTransit.Activities.Files
                 0,
                 executeContext.CancellationToken);
 
+            var sourceFilePath = executeContext.GetVariable<string>(executeContext.Arguments.FilePathVariableName);
+            if (string.IsNullOrEmpty(sourceFilePath))
+                throw new InvalidOperationException($"Upload activity requires variable '{executeContext.Arguments.FilePathVariableName}' with source file path.");
+
             try
             {
-                using var fileStream = File.OpenRead(executeContext.Arguments.SourceFilePath);
+                using var fileStream = File.OpenRead(sourceFilePath);
 
                 var uploadResult = await storageHandler.UploadFileAsync(
                     fileStream,
diff --git a/Infrastructure/MassTransit/Arguments/UploadFileToBucketArguments.cs b/Infrastructure/MassTransit/Arguments/UploadFileToBucketArguments.cs
index 7f58fcd..ab6ccda 100644
--- a/Infrastructure/MassTransit/Arguments/UploadFileToBucketArguments.cs
+++ b/Infrastructure/MassTransit/Arguments/UploadFileToBucketArguments.cs
@@ -1,7 +1,7 @@
 namespace Musify.Infrastructure.MassTransit.Arguments
 {
     public record UploadFileToBucketArguments(
-        string SourceFilePath,
+        string FilePathVariableName,
         string ContentType,
         string DestinationBucketName,
         string DestinationKeyName);