Commit a01e888c authored by Wout De Nolf's avatar Wout De Nolf
Browse files

Merge branch 'fixes_olof' into 'main'

Fixes olof

See merge request !19
parents a7a6e67d c0e1de3e
Pipeline #55737 passed with stages
in 1 minute and 1 second
...@@ -79,7 +79,7 @@ class AbstractActor(ThreadCountingActor): ...@@ -79,7 +79,7 @@ class AbstractActor(ThreadCountingActor):
return self.started return self.started
def setStarted(self): def setStarted(self):
logger.debug("Setting finished of {0} to True".format(self.name)) logger.debug("Setting started of {0} to True".format(self.name))
self.started = True self.started = True
def hasFinished(self): def hasFinished(self):
......
...@@ -15,10 +15,12 @@ class PyBesWorkflowDbClient(PyMongoWorkflowDbClient, register_name="pybes"): ...@@ -15,10 +15,12 @@ class PyBesWorkflowDbClient(PyMongoWorkflowDbClient, register_name="pybes"):
initiator = os.environ.get("PYPUSHFLOW_INITIATOR", "Unknown") initiator = os.environ.get("PYPUSHFLOW_INITIATOR", "Unknown")
host = os.environ.get("PYPUSHFLOW_HOST", "Unknown") host = os.environ.get("PYPUSHFLOW_HOST", "Unknown")
port = os.environ.get("PYPUSHFLOW_PORT", "Unknown") port = os.environ.get("PYPUSHFLOW_PORT", "Unknown")
requestId = os.environ.get("PYPUSHFLOW_OBJECTID", "Unknown")
return { return {
"initiator": initiator, "initiator": initiator,
"host": host, "host": host,
"port": port, "port": port,
"Request ID": requestId,
} }
def generateWorkflowId(self, oid: Optional[str] = None): def generateWorkflowId(self, oid: Optional[str] = None):
......
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