From 52c158bae2bee36375661fe8ee41bbb48b8e31e6 Mon Sep 17 00:00:00 2001
From: Jorrit Schaap <schaap@astron.nl>
Date: Thu, 30 Jun 2016 08:07:48 +0000
Subject: [PATCH] Task #8598: applied some patches from production
---
LTA/LTAIngest/ingestpipeline.py | 3 +++
1 file changed, 3 insertions(+)
diff --git a/LTA/LTAIngest/ingestpipeline.py b/LTA/LTAIngest/ingestpipeline.py
index dc6217ef01a..7033a95cefb 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)]
--
GitLab