Skip to content
Snippets Groups Projects
Commit 6684e2f0 authored by Manuela Kuhn's avatar Manuela Kuhn
Browse files

Enabled metadata sending after file removal

parent fb3a2db7
No related branches found
No related tags found
No related merge requests found
...@@ -229,7 +229,7 @@ def finishDataHandling (log, targets, sourceFile, targetFile, metadata, openConn ...@@ -229,7 +229,7 @@ def finishDataHandling (log, targets, sourceFile, targetFile, metadata, openConn
#send message to metadata targets #send message to metadata targets
if targets_metadata: if targets_metadata:
try: 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.") log.debug("Passing metadata multipart-message for file " + str(sourceFile) + "...done.")
except: except:
...@@ -245,6 +245,15 @@ def finishDataHandling (log, targets, sourceFile, targetFile, metadata, openConn ...@@ -245,6 +245,15 @@ def finishDataHandling (log, targets, sourceFile, targetFile, metadata, openConn
prop["removeFlag"] = False 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): def clean (prop):
pass pass
......
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