diff --git a/LTA/LTAIngest/ingestpipeline.py b/LTA/LTAIngest/ingestpipeline.py
index dc6217ef01a4fe0db2cefad9fa4e136aae3ba011..7033a95cefb0c348e3cbb9e5743f4f0bcc71c6c2 100755
--- a/LTA/LTAIngest/ingestpipeline.py
+++ b/LTA/LTAIngest/ingestpipeline.py
@@ -186,6 +186,9 @@ class IngestPipeline():
       hostname = 'localhost'
       cmd = ["cd %s && %s -Xmx256m -cp %s/qpid-properties/lexar001.offline.lofar:%s/ltacp.jar nl.astron.ltacp.client.LtaCp %s %s %s %s" % (self.LocationDir, javacmd, ltacppath, ltacppath, hostname, self.ltacpport, self.PrimaryUri, self.Source)]
     else:
+      if self.HostLocation.startswith('locus') and not self.HostLocation.endswith('offline.lofar'):
+        self.HostLocation += '.offline.lofar'
+
       # copy data with ltacp from a remote host, so use ssh
       if self.PrimaryUri:
         cmd = ["ssh",  "-T", "ingest@" +self.HostLocation, "cd %s;%s -Xmx256m -cp %s/qpid-properties/lexar001.offline.lofar:%s/ltacp.jar nl.astron.ltacp.client.LtaCp %s %s %s %s" % (self.LocationDir, javacmd, ltacppath, ltacppath, hostname, self.ltacpport, self.PrimaryUri, self.Source)]