diff --git a/transfer_service/retrieve_preprocessor.py b/transfer_service/retrieve_preprocessor.py
index 2a3008989f75bbfb23285ae31bd19d54d8450b5e..faaee7e84ee0ecdab1869a53a0f984cd9e8645c4 100644
--- a/transfer_service/retrieve_preprocessor.py
+++ b/transfer_service/retrieve_preprocessor.py
@@ -13,6 +13,7 @@ class RetrievePreprocessor(TaskExecutor):
                                   self.params["host"],
                                   self.params.getint("port"),
                                   self.params["db"])
+        self.nodeList = []
         super(RetrievePreprocessor, self).__init__()
 
     def run(self):
@@ -22,10 +23,11 @@ class RetrievePreprocessor(TaskExecutor):
         while True:
             self.wait()
             if self.destQueue.len() < self.maxReadyJobs and self.srcQueue.len() > 0:
-                self.jobObj = self.srcQueue.getJob()                
-                
-                # do something here...
-                
+                self.jobObj = self.srcQueue.getJob()
+                vospacePath = self.jobObj.jobInfo["transfer"]["target"].split("!vospace")[1]
+                osPath = dbConn.getOSPath(vospacePath)
+                self.nodeList.append(osPath)
+                self.jobObj.jobInfo["transfer"]["nodeList"] = self.nodeList
                 self.srcQueue.extractJob()
                 self.destQueue.insertJob(self.jobObj)
                 print(f"Job {self.jobObj.jobId} MOVED from {self.srcQueue.name()} to {self.destQueue.name()}")
\ No newline at end of file