Skip to content
This repository has been archived by the owner on Oct 23, 2024. It is now read-only.

Commit

Permalink
Mark MarathonSchedulerActorTest - Restart deployment after failover a…
Browse files Browse the repository at this point in the history
…s stable again

Summary:
Couldn't find anything wrong with the test, so let's see how it behaves when marked as stable again.
If it fails we'll have more logs and I'll take a look at it again.

Fixes: #4933

Test Plan: unit-test

Reviewers: jeschkies, unterstein

Reviewed By: jeschkies, unterstein

Subscribers: jenkins, marathon-team

Differential Revision: https://phabricator.mesosphere.com/D429
  • Loading branch information
Aleksey Dukhovniy committed Jan 20, 2017
1 parent 3ecccde commit ad64d8b
Showing 1 changed file with 3 additions and 15 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,6 @@ import akka.event.EventStream
import akka.stream.scaladsl.Source
import akka.testkit._
import akka.util.Timeout
import mesosphere.Unstable
import mesosphere.marathon.MarathonSchedulerActor._
import mesosphere.marathon.core.election.{ ElectionService, LocalLeadershipEvent }
import mesosphere.marathon.core.event._
Expand Down Expand Up @@ -420,8 +419,7 @@ class MarathonSchedulerActorTest extends MarathonActorSupport
}
}

// Marked Unstab
test("Restart deployments after failover", Unstable) {
test("Restart deployments after failover") {
val f = new Fixture
import f._
val app = AppDefinition(
Expand All @@ -439,19 +437,9 @@ class MarathonSchedulerActorTest extends MarathonActorSupport
deploymentRepo.all() returns Source.single(plan)
deploymentRepo.store(plan) returns Future.successful(Done)
instanceTracker.specInstancesLaunchedSync(app.id) returns Seq.empty[Instance]
instanceTracker.specInstances(app.id) returns Future.successful(Seq.empty[Instance])

val schedulerActor = system.actorOf(
MarathonSchedulerActor.props(
schedulerActions,
deploymentManagerProps,
historyActorProps,
hcManager,
killService,
queue,
holder,
electionService,
system.eventStream
))
val schedulerActor = createActor()

try {
schedulerActor ! LocalLeadershipEvent.ElectedAsLeader
Expand Down

0 comments on commit ad64d8b

Please sign in to comment.