Additional logging of workflowID/RunID in Matching Engine.

Reviewers: samar, maxim, tamer Differential Revision: https://code.uberinternal.com/D735210
MartinGomes · Feb 10, 2017 · de95dba · de95dba
1 parent 4eb43dd
commit de95dba
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/service/matching/matchingEngine.go b/service/matching/matchingEngine.go
@@ -170,7 +170,8 @@ func (e *matchingEngineImpl) getTaskListContext(taskList *taskListID) (*taskList
 // AddDecisionTask either delivers task directly to waiting poller or save it into task list persistence.
 func (e *matchingEngineImpl) AddDecisionTask(addRequest *m.AddDecisionTaskRequest) error {
 	taskListName := addRequest.GetTaskList().GetName()
-	e.logger.Debugf("Received AddDecisionTask for taskList=%v", addRequest.TaskList.Name)
+	e.logger.Debugf("Received AddDecisionTask for taskList=%v, WorkflowID=%v, RunID=%v",
+		addRequest.TaskList.Name, addRequest.Execution.WorkflowId, addRequest.Execution.RunId)
 	taskList := newTaskListID(taskListName, persistence.TaskListTypeDecision)
 	t, err := e.getTaskListContext(taskList)
 	if err != nil {
@@ -212,7 +213,8 @@ func (e *matchingEngineImpl) AddDecisionTask(addRequest *m.AddDecisionTaskReques
 // AddActivityTask either delivers task directly to waiting poller or save it into task list persistence.
 func (e *matchingEngineImpl) AddActivityTask(addRequest *m.AddActivityTaskRequest) error {
 	taskListName := addRequest.GetTaskList().GetName()
-	e.logger.Debugf("Received AddActivityTask for taskList=%v", taskListName)
+	e.logger.Debugf("Received AddActivityTask for taskList=%v WorkflowID=%v, RunID=%v",
+		taskListName, addRequest.Execution.WorkflowId, addRequest.Execution.RunId)
 	taskList := newTaskListID(taskListName, persistence.TaskListTypeActivity)
 	t, err := e.getTaskListContext(taskList)
 	if err != nil {