Skip to content
Snippets Groups Projects
Commit 30ce1a17 authored by Charlotte Hausman's avatar Charlotte Hausman
Browse files

fixing workflow event routing key and typo

parent fdca1268
No related branches found
No related tags found
No related merge requests found
......@@ -46,7 +46,7 @@ class WorkflowEventChannel(ChannelDefinition[WorkflowEvent]):
)
def routing_key_for(self, event: WorkflowEvent) -> str:
return f"{event.job_name}.{event.job_id}.{event.type.name.lower()}"
return f"{event.job_name}.{event.workflow_request_id}.{event.type.name.lower()}"
def exchange(self) -> str:
return self.EXCHANGE
......
......@@ -486,7 +486,7 @@ class WorkflowService(WorkflowServiceIF):
log_file = self._execute_prepared(temp_folder)
# 6. start reading log file
monitor = WorkflowMonitor(logfile_path=(log_file), workflow_request_id=request.workflow_request_id)
monitor = WorkflowMonitor(logfile_path=str(log_file), workflow_request_id=request.workflow_request_id)
# parse events from log
events = monitor.events
with workflow_events:
......
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