Skip to content
Snippets Groups Projects
Commit ad4f96f2 authored by Jorrit Schaap's avatar Jorrit Schaap
Browse files

Task #8598: applied some patches from production

parent a7b94cc0
Branches
Tags
No related merge requests found
...@@ -186,6 +186,9 @@ class IngestPipeline(): ...@@ -186,6 +186,9 @@ class IngestPipeline():
hostname = 'localhost' 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)] 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: 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 # copy data with ltacp from a remote host, so use ssh
if self.PrimaryUri: 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)] 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)]
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment