Check validity of ActorLineage

This commit is contained in:
Lukas Joswiak 2021-04-28 15:40:13 -07:00
parent 7d308c7199
commit 045d20ab7a

View File

@ -275,7 +275,10 @@ ActorLineageProfilerT::ActorLineageProfilerT() : impl(new ProfilerImpl()) {
std::bind(&ActorLineageSet::copy, std::ref(IAsyncFileSystem::filesystem()->getActorLineageSet())));
collection->collector()->addGetter(WaitState::Running, []() {
auto res = currentLineageThreadSafe.get();
if (res.isValid()) {
return std::vector<Reference<ActorLineage>>({ res });
}
return std::vector<Reference<ActorLineage>>();
});
}