Commit 6589e42c authored by Wout De Nolf's avatar Wout De Nolf
Browse files

use the task identifier as 'script' for mongo logging

parent 3efff860
Pipeline #67772 passed with stages
in 1 minute and 23 seconds
......@@ -81,6 +81,17 @@ class EwoksPythonActor(PythonActor):
inData[infokey]["node_attrs"] = self.node_attrs
return super().trigger(inData)
def uploadInDataToMongo(self, **kw):
task_identifier = self.node_attrs.get("task_identifier")
if task_identifier:
kw["script"] = task_identifier
super().uploadInDataToMongo(**kw)
def uploadOutDataToMongo(self, **kw):
task_identifier = self.node_attrs.get("task_identifier")
if task_identifier:
super().uploadOutDataToMongo(**kw)
class ConditionalActor(AbstractActor):
"""Triggers downstream actors when conditions are fulfilled."""
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment