#include #include #include "daggy/executors/ForkingTaskExecutor.hpp" #include "daggy/Scheduler.hpp" #include "catch.hpp" TEST_CASE("Basic Scheduler Execution", "[scheduler]") { daggy::executor::ForkingTaskExecutor ex(10); daggy::Scheduler sched(ex); std::vector tasks { daggy::Task{ "task_a", { "/usr/bin/echo", "task_a"}, 3, 30, { "task_c"} } , daggy::Task{ "task_b", { "/usr/bin/echo", "task_b"}, 3, 30, { "task_c" } } , daggy::Task{ "task_c", { "/usr/bin/echo", "task_c"}, 3, 30, {} } }; SECTION("Simple Run") { auto fut_a = sched.scheduleDAG("Simple 1", tasks, {}); auto fut_b = sched.scheduleDAG("Simple 2", tasks, {}); fut_a.get(); fut_b.get(); } }