Skip to content

Commit

Permalink
Fix test
Browse files Browse the repository at this point in the history
  • Loading branch information
Will-Lo committed Jun 27, 2022
1 parent c8450a7 commit 726e13a
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,6 @@
import java.util.Map;
import java.util.Properties;
import org.apache.gobblin.configuration.ConfigurationKeys;
import org.apache.gobblin.exception.QuotaExceededException;
import org.apache.gobblin.runtime.JobException;
import org.apache.gobblin.runtime.api.FlowSpec;
import org.apache.gobblin.runtime.api.JobSpec;
Expand Down Expand Up @@ -338,7 +337,7 @@ public void testJobSchedulerAddFlowQuotaExceeded() throws Exception {
scheduler.setActive(true);

scheduler.onAddSpec(flowSpec0); //Ignore the response for this request
Assert.assertThrows(QuotaExceededException.class, () -> scheduler.onAddSpec(flowSpec1));
Assert.assertThrows(RuntimeException.class, () -> scheduler.onAddSpec(flowSpec1));

Assert.assertEquals(scheduler.scheduledFlowSpecs.size(), 1);
// Second flow should not be added to scheduled flows since it was rejected
Expand Down

0 comments on commit 726e13a

Please sign in to comment.