probagate changes about nodeKey

protobuf/types/workflow.proto

@@ -34,7 +34,7 @@ message Workflow {
     string instanceHash = 2;      // Hash of the instance that triggers the workflow.
     string key = 3;               // Key that triggers the workflow (event key or task key).
     repeated Filter filters = 4;  // List of filters to apply on the data of the event/result.
-    string nodeKey = 5;       // First node to trigger when the workflow starts.
+    string nodeKey = 5;           // First node to trigger when the workflow starts.
   }
 
   // Definition of the node to execute when the workflow is triggered.

scheduler/scheduler.go

@@ -62,12 +62,12 @@ func (s *Scheduler) processTrigger(trigger workflow.TriggerType, instanceHash ha
 	}
 	for _, wf := range workflows {
 		if wf.Trigger.Match(trigger, instanceHash, key, data) {
-			nextStep, err := wf.FindNode(wf.Trigger.InitialNode)
+			nextStep, err := wf.FindNode(wf.Trigger.NodeKey)
 			if err != nil {
 				s.ErrC <- err
 				continue
 			}
-			if _, err := s.execution.Execute(wf.Hash, nextStep.InstanceHash, eventHash, execHash, wf.Trigger.InitialNode, nextStep.TaskKey, data, []string{}); err != nil {
+			if _, err := s.execution.Execute(wf.Hash, nextStep.InstanceHash, eventHash, execHash, wf.Trigger.NodeKey, nextStep.TaskKey, data, []string{}); err != nil {
 				s.ErrC <- err
 			}
 		}

server/grpc/api/workflow.go

@@ -139,7 +139,7 @@ func fromProtoWorkflow(wf *types.Workflow) (*workflow.Workflow, error) {
 			Type:         triggerType,
 			InstanceHash: instanceHash,
 			Key:          wf.Trigger.Key,
-			InitialNode:  wf.Trigger.InitialNode,
+			NodeKey:      wf.Trigger.NodeKey,
 			Filters:      fromProtoFilters(wf.Trigger.Filters),
 		},
 		Nodes: nodes,
@@ -203,7 +203,7 @@ func toProtoWorkflow(wf *workflow.Workflow) *types.Workflow {
 			InstanceHash: wf.Trigger.InstanceHash.String(),
 			Key:          wf.Trigger.Key,
 			Filters:      toProtoFilters(wf.Trigger.Filters),
-			InitialNode:  wf.Trigger.InitialNode,
+			NodeKey:      wf.Trigger.NodeKey,
 		},
 		Nodes: toProtoWorkflowNodes(wf.Nodes),
 		Edges: toProtoWorkflowEdges(wf.Edges),