ma27/hydra
0
0
Fork 0
forked from lix-project/hydra
Code Pull requests Activity

hydra-queue-runner: fix stats

Browse source
This commit is contained in:
Maximilian Bosch 2023-06-25 17:25:43 +02:00
parent 13ef4e3c5d
commit 5c35d1be20
No known key found for this signature in database
GPG key ID: 9A6EEA275CA5BE0A
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/hydra-queue-runner/hydra-queue-runner.cc
View file

@ -618,7 +618,7 @@ void State::dumpStatus(Connection & conn)
}
{
auto jobsets_json = statusJson["jobsets"] = json::object();
auto jobsets_json = json::object();
auto jobsets_(jobsets.lock());
for (auto & jobset : *jobsets_) {
jobsets_json[jobset.first.first + ":" + jobset.first.second] = {
@ -626,10 +626,11 @@ void State::dumpStatus(Connection & conn)
{"seconds", jobset.second->getSeconds()},
};
}
statusJson["jobsets"] = jobsets_json;
}
{
auto machineTypesJson = statusJson["machineTypes"] = json::object();
auto machineTypesJson = json::object();
auto machineTypes_(machineTypes.lock());
for (auto & i : *machineTypes_) {
auto machineTypeJson = machineTypesJson[i.first] = {
@ -642,6 +643,7 @@ void State::dumpStatus(Connection & conn)
if (i.second.running == 0)
machineTypeJson["lastActive"] = std::chrono::system_clock::to_time_t(i.second.lastActive);
}
statusJson["machineTypes"] = machineTypesJson;
}
auto store = getDestStore();