From 511a184c3c4d94cc832c5e5500453f6fc2bd00d3 Mon Sep 17 00:00:00 2001 From: Dragoslav Pavkovic Date: Thu, 18 May 2017 23:52:50 +0200 Subject: [PATCH] accessing triggering event within resulted workflow execution, vamp 973 --- .../scala/io/vamp/workflow_driver/KubernetesWorkflowActor.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/scala/io/vamp/workflow_driver/KubernetesWorkflowActor.scala b/src/main/scala/io/vamp/workflow_driver/KubernetesWorkflowActor.scala index 38a7e87..12a112d 100644 --- a/src/main/scala/io/vamp/workflow_driver/KubernetesWorkflowActor.scala +++ b/src/main/scala/io/vamp/workflow_driver/KubernetesWorkflowActor.scala @@ -36,7 +36,7 @@ class KubernetesWorkflowActor extends DaemonWorkflowDriver with ContainerDriverM } protected override def schedule(data: Any): PartialFunction[Workflow, Future[Any]] = super.schedule(data) orElse { - case w if data.isInstanceOf[Event] && w.schedule.isInstanceOf[EventSchedule] ⇒ enrich(w).flatMap { workflow ⇒ + case w if data.isInstanceOf[Event] && w.schedule.isInstanceOf[EventSchedule] ⇒ enrich(w, data).flatMap { workflow ⇒ validateDeployable(workflow.breed.asInstanceOf[DefaultBreed].deployable)