- Checkpointing work before I restart the IDE.
This commit is contained in:
@@ -4,8 +4,26 @@
|
|||||||
#include <argparse.hpp>
|
#include <argparse.hpp>
|
||||||
|
|
||||||
#include <daggy/Server.hpp>
|
#include <daggy/Server.hpp>
|
||||||
|
|
||||||
|
// Add executors here
|
||||||
#include <daggy/executors/task/ForkingTaskExecutor.hpp>
|
#include <daggy/executors/task/ForkingTaskExecutor.hpp>
|
||||||
|
|
||||||
|
// Add loggers here
|
||||||
#include <daggy/loggers/dag_run/OStreamLogger.hpp>
|
#include <daggy/loggers/dag_run/OStreamLogger.hpp>
|
||||||
|
#include <daggy/loggers/dag_run/FileSystemLogger.hpp>
|
||||||
|
|
||||||
|
struct Options {
|
||||||
|
Pistache::Address listenAddress = "0.0.0.0";
|
||||||
|
uint16_t listenPort = 2503;
|
||||||
|
size_t webThreads = 50;
|
||||||
|
size_t dagThreads = 20;
|
||||||
|
|
||||||
|
// Pool name -> Executor Type + nWorkers
|
||||||
|
std::unordered_map<std::string, std::pair<std::string, size_t>> executors;
|
||||||
|
|
||||||
|
// Logger Config
|
||||||
|
std::vector<std::unique_ptr<daggy::loggers::dag_run::DAGRunLogger>> loggers;
|
||||||
|
};
|
||||||
|
|
||||||
int main(int argc, char **argv) {
|
int main(int argc, char **argv) {
|
||||||
argparse::ArgumentParser args("Daggy");
|
argparse::ArgumentParser args("Daggy");
|
||||||
@@ -19,5 +37,7 @@ int main(int argc, char **argv) {
|
|||||||
.help("Port to listen to")
|
.help("Port to listen to")
|
||||||
.action([](const std::string &value) { return std::stoi(value); });
|
.action([](const std::string &value) { return std::stoi(value); });
|
||||||
|
|
||||||
|
// Set some defaults
|
||||||
|
|
||||||
// daggy::Server endpoint(10);
|
// daggy::Server endpoint(10);
|
||||||
}
|
}
|
||||||
Reference in New Issue
Block a user