-1, "(o)", "(ss)", unit.c_str(), "flush").get("(o)", &job);
INFO(SINK, "Waiting for job: " + std::string(job));
if (!watch.waitForJob(job))
- throw runtime::Exception("Stopping unit: " + unit + " failed");
+ ERROR(SINK, "Stopping unit: " + unit + " failed");
};
for (const std::string &unit : preprocessUnits) {
INFO(SINK, "Waiting for job: " + std::string(job));
if (!watch.waitForJob(job))
- throw runtime::Exception("Starting unit: " + unit + " failed");
+ ERROR(SINK, "Starting unit: " + unit + " failed");
}
unsigned int getOptions()