@Test public void workflowStartTimeTest3() throws Exception { WorkflowID wfID1 = new WorkflowID("wf1"); Schedule sch1 = makeHourlySchedule(); SchedulingStrategy str1 = makeSerialSchedulingStrategy(); Trigger tr1 = makeAlwaysTrigger(); MockExternalService srv1 = new MockExternalService(new MockExternalService.MockExternalStatusRunning()); int maxRetryCount = 0; DateTime currentDT = DateTime.now(DateTimeZone.UTC); ScheduledTime startTime = new ScheduledTime(currentDT.plusDays(10)); Workflow wf1 = new Workflow(wfID1, sch1, str1, tr1, srv1, maxRetryCount, startTime, Workflow.DEFAULT_WAIT_TIMEOUT_SECONDS, emptyWorkflowInfo); WorkflowConfiguration cfg = new WorkflowConfiguration(); cfg.addWorkflow(wf1); MemoryStateDatabase db = new MemoryStateDatabase(); Scheduler sched = new Scheduler(cfg, 7 * 24); sched.step(new ScheduledTime(currentDT), mockedConnection); Assert.assertEquals(0, connection.size()); }
public void step(ScheduledTime current, StateDatabaseConnection connection) throws Exception { step(current, Collections.<WorkflowID>emptySet(), connection); }
Scheduler { public void step(ScheduledTime current, StateDatabaseConnection connection) throws Exception { step(current, Collections.<WorkflowID>emptySet(), connection); } }
Scheduler { public void step(ScheduledTime current, StateDatabaseConnection connection) throws Exception { step(current, Collections.<WorkflowID>emptySet(), connection); } Scheduler(WorkflowConfiguration configuration, int slidingWindowHours); }
Scheduler { public void step(ScheduledTime current, StateDatabaseConnection connection) throws Exception { step(current, Collections.<WorkflowID>emptySet(), connection); } Scheduler(WorkflowConfiguration configuration, int slidingWindowHours); void step(ScheduledTime current, StateDatabaseConnection connection); void step(ScheduledTime current, Set<WorkflowID> workflowIDs, StateDatabaseConnection connection); List<SlotState> getSlotStatesIncludingMarkedForRerun(Workflow wf, ScheduledTime current, ScheduledTime start, ScheduledTime end, StateDatabaseConnection connection); List<SlotState> getSlotStates(Workflow wf, ScheduledTime start, ScheduledTime end, StateDatabaseConnection connection); ScheduledTime getWorkflowStartTime(Workflow wf, ScheduledTime current); int getSlidingWindowHours(); WorkflowConfiguration getWorkflowConfiguration(); }
Scheduler { public void step(ScheduledTime current, StateDatabaseConnection connection) throws Exception { step(current, Collections.<WorkflowID>emptySet(), connection); } Scheduler(WorkflowConfiguration configuration, int slidingWindowHours); void step(ScheduledTime current, StateDatabaseConnection connection); void step(ScheduledTime current, Set<WorkflowID> workflowIDs, StateDatabaseConnection connection); List<SlotState> getSlotStatesIncludingMarkedForRerun(Workflow wf, ScheduledTime current, ScheduledTime start, ScheduledTime end, StateDatabaseConnection connection); List<SlotState> getSlotStates(Workflow wf, ScheduledTime start, ScheduledTime end, StateDatabaseConnection connection); ScheduledTime getWorkflowStartTime(Workflow wf, ScheduledTime current); int getSlidingWindowHours(); WorkflowConfiguration getWorkflowConfiguration();  }