From 6684e2f09d994e32443fe8308ef2311231afae03 Mon Sep 17 00:00:00 2001
From: Manuela Kuhn <manuela.kuhn@desy.de>
Date: Tue, 10 May 2016 10:29:57 +0200
Subject: [PATCH] Enabled metadata sending after file removal
---
src/sender/dataFetchers/getFromFile.py | 11 ++++++++++-
1 file changed, 10 insertions(+), 1 deletion(-)
diff --git a/src/sender/dataFetchers/getFromFile.py b/src/sender/dataFetchers/getFromFile.py
index 09244bca..67153938 100644
--- a/src/sender/dataFetchers/getFromFile.py
+++ b/src/sender/dataFetchers/getFromFile.py
@@ -229,7 +229,7 @@ def finishDataHandling (log, targets, sourceFile, targetFile, metadata, openConn
#send message to metadata targets
if targets_metadata:
try:
- __sendToTargets(log, targets_metadata, sourceFile, targetFile, openConnections, metadata, None, context)
+ __sendToTargets(log, targets_metadata, sourceFile, targetFile, openConnections, metadata, None, context, prop["timeout"])
log.debug("Passing metadata multipart-message for file " + str(sourceFile) + "...done.")
except:
@@ -245,6 +245,15 @@ def finishDataHandling (log, targets, sourceFile, targetFile, metadata, openConn
prop["removeFlag"] = False
+ #send message to metadata targets
+ if targets_metadata:
+ try:
+ __sendToTargets(log, targets_metadata, sourceFile, targetFile, openConnections, metadata, None, context, prop["timeout"] )
+ log.debug("Passing metadata multipart-message for file " + str(sourceFile) + "...done.")
+
+ except:
+ log.error("Unable to send metadata multipart-message for file " + str(sourceFile), exc_info=True)
+
def clean (prop):
pass
--
GitLab