@Test public void run() throws Exception { runWorkflow("basic", loadYamlResource("/io/digdag/core/workflow/basic.dig")); }
public void run() throws InterruptedException { runWhile(() -> true); }
WorkflowExecutor { public void run() throws InterruptedException { runWhile(() -> true); } }
WorkflowExecutor { public void run() throws InterruptedException { runWhile(() -> true); } @Inject  WorkflowExecutor(
            ProjectStoreManager rm,
            SessionStoreManager sm,
            TransactionManager tm,
            TaskQueueDispatcher dispatcher,
            WorkflowCompiler compiler,
            ConfigFactory cf,
            ObjectMapper archiveMapper,
            Config systemConfig); }
WorkflowExecutor { public void run() throws InterruptedException { runWhile(() -> true); } @Inject  WorkflowExecutor(
            ProjectStoreManager rm,
            SessionStoreManager sm,
            TransactionManager tm,
            TaskQueueDispatcher dispatcher,
            WorkflowCompiler compiler,
            ConfigFactory cf,
            ObjectMapper archiveMapper,
            Config systemConfig); StoredSessionAttemptWithSession submitWorkflow(int siteId,
            AttemptRequest ar,
            WorkflowDefinition def); T submitTransaction(int siteId, WorkflowSubmitterAction<T> func); StoredSessionAttemptWithSession submitTasks(int siteId, AttemptRequest ar,
            WorkflowTaskList tasks); void storeTasks(
            SessionControlStore store,
            StoredSessionAttemptWithSession storedAttempt,
            WorkflowDefinition def,
            List<ResumingTask> resumingTasks,
            List<SessionMonitor> sessionMonitors); void storeTasks(
            SessionControlStore store,
            StoredSessionAttemptWithSession storedAttempt,
            WorkflowTaskList tasks,
            List<ResumingTask> resumingTasks,
            List<SessionMonitor> sessionMonitors); boolean killAttemptById(int siteId, long attemptId); void noticeRunWhileConditionChange(); void run(); StoredSessionAttemptWithSession runUntilDone(long attemptId); void runUntilAllDone(); void runWhile(BooleanSupplier cond); List<TaskRequest> getTaskRequests(List<TaskQueueLock> locks); boolean taskFailed(int siteId, long taskId, String lockId, AgentId agentId,
            Config error); boolean taskSucceeded(int siteId, long taskId, String lockId, AgentId agentId,
            TaskResult result); boolean retryTask(int siteId, long taskId, String lockId, AgentId agentId,
            int retryInterval, Config retryStateParams,
            Optional<Config> error); Optional<Long> addMonitorTask(TaskControl lockedTask, String type, Config taskConfig); }
WorkflowExecutor { public void run() throws InterruptedException { runWhile(() -> true); } @Inject  WorkflowExecutor(
            ProjectStoreManager rm,
            SessionStoreManager sm,
            TransactionManager tm,
            TaskQueueDispatcher dispatcher,
            WorkflowCompiler compiler,
            ConfigFactory cf,
            ObjectMapper archiveMapper,
            Config systemConfig); StoredSessionAttemptWithSession submitWorkflow(int siteId,
            AttemptRequest ar,
            WorkflowDefinition def); T submitTransaction(int siteId, WorkflowSubmitterAction<T> func); StoredSessionAttemptWithSession submitTasks(int siteId, AttemptRequest ar,
            WorkflowTaskList tasks); void storeTasks(
            SessionControlStore store,
            StoredSessionAttemptWithSession storedAttempt,
            WorkflowDefinition def,
            List<ResumingTask> resumingTasks,
            List<SessionMonitor> sessionMonitors); void storeTasks(
            SessionControlStore store,
            StoredSessionAttemptWithSession storedAttempt,
            WorkflowTaskList tasks,
            List<ResumingTask> resumingTasks,
            List<SessionMonitor> sessionMonitors); boolean killAttemptById(int siteId, long attemptId); void noticeRunWhileConditionChange(); void run(); StoredSessionAttemptWithSession runUntilDone(long attemptId); void runUntilAllDone(); void runWhile(BooleanSupplier cond); List<TaskRequest> getTaskRequests(List<TaskQueueLock> locks); boolean taskFailed(int siteId, long taskId, String lockId, AgentId agentId,
            Config error); boolean taskSucceeded(int siteId, long taskId, String lockId, AgentId agentId,
            TaskResult result); boolean retryTask(int siteId, long taskId, String lockId, AgentId agentId,
            int retryInterval, Config retryStateParams,
            Optional<Config> error); Optional<Long> addMonitorTask(TaskControl lockedTask, String type, Config taskConfig);  }