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

Task #8598: applied some patches from production

parent 65d3142b
No related branches found
No related tags found
No related merge requests found
......@@ -410,6 +410,12 @@ class IngestPipeline():
try:
sip_host = self.job['SIPLocation'].split(':')[0]
sip_path = self.job['SIPLocation'].split(':')[1]
# eor dawn nodes are not known in dns
# convert to ip address
for i in range(1, 33):
sip_host = sip_host.replace('node%d.intra.dawn.rug.nl' % (i+100,), '10.196.232.%d' % (i+10,))
cmd = ['ssh', '-tt', '-n', '-x', '-q', '%s@%s' % (self.user, sip_host), 'cat %s' % sip_path]
self.logger.debug("GetSIP for %s with mom2DPId %s - StorageTicket %s - FileName %s - Uri %s - cmd %s" % (self.JobId, self.ArchiveId, self.ticket, self.FileName, self.PrimaryUri, ' ' .join(cmd)))
p = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment