Skip to content

Commit

Permalink
fix invalidate
Browse files Browse the repository at this point in the history
  • Loading branch information
Thibault Jeandet committed Jun 23, 2017
1 parent 6c81569 commit b76a295
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -120,7 +120,6 @@ class EngineJobExecutionActor(replyTo: ActorRef,
// When CheckingJobStore, the FSM always has NoData
when(CheckingJobStore) {
case Event(JobNotComplete, NoData) =>
writeCallCachingModeToMetadata()
prepareJob()
case Event(JobComplete(jobResult), NoData) =>
val response = jobResult match {
Expand Down Expand Up @@ -408,6 +407,7 @@ class EngineJobExecutionActor(replyTo: ActorRef,

def createJobPreparationActor(jobPrepProps: Props, name: String): ActorRef = context.actorOf(jobPrepProps, name)
def prepareJob() = {
writeCallCachingModeToMetadata()
val jobPreparationActorName = s"BackendPreparationActor_for_$jobTag"
val jobPrepProps = JobPreparationActor.props(executionData, jobDescriptorKey, factory, workflowDockerLookupActor = workflowDockerLookupActor,
initializationData, serviceRegistryActor = serviceRegistryActor, ioActor = ioActor, backendSingletonActor = backendSingletonActor)
Expand Down

0 comments on commit b76a295

Please sign in to comment.