From cbd493ec386bd0f2d899cbc01b8103fee77cdb06 Mon Sep 17 00:00:00 2001 From: Ian Roddis Date: Fri, 28 Jan 2022 13:28:29 -0400 Subject: [PATCH] Fixing issue with daggyd config parsing --- daggyd/daggyd/daggyd.cpp | 3 ++- libdaggy/src/executors/task/DaggyRunnerTaskExecutor.cpp | 1 + 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/daggyd/daggyd/daggyd.cpp b/daggyd/daggyd/daggyd.cpp index 64ee6e0..368842c 100644 --- a/daggyd/daggyd/daggyd.cpp +++ b/daggyd/daggyd/daggyd.cpp @@ -209,6 +209,7 @@ std::unique_ptr executorFactory(const rj::Value &config) "DaggyRunnerExecutor runners must be an array of urls"); exe->addRunner(runners[i].GetString()); } + return exe; } else if (name == "SSHTaskExecutor") { if (!execConfig.HasMember("hosts")) @@ -251,7 +252,7 @@ std::unique_ptr executorFactory(const rj::Value &config) return exe; } - throw std::runtime_error("Unknown executor type: " + name); + throw std::runtime_error("Unknown executor type: >>" + name + "<<"); } int main(int argc, char **argv) diff --git a/libdaggy/src/executors/task/DaggyRunnerTaskExecutor.cpp b/libdaggy/src/executors/task/DaggyRunnerTaskExecutor.cpp index a830264..7db6a00 100644 --- a/libdaggy/src/executors/task/DaggyRunnerTaskExecutor.cpp +++ b/libdaggy/src/executors/task/DaggyRunnerTaskExecutor.cpp @@ -88,6 +88,7 @@ DaggyRunnerTaskExecutor::~DaggyRunnerTaskExecutor() { running_ = false; monitorWorker_.join(); + dispatchWorker_.join(); } std::string DaggyRunnerTaskExecutor::description() const