nixos/nix
1
1
Fork 0
mirror of https://github.com/NixOS/nix.git synced 2025-11-11 04:56:01 +01:00
Code Activity

nix flake prefetch-inputs: Keep going if an input fails

Browse source
This commit is contained in:
Eelco Dolstra 2025-06-30 14:52:25 +02:00
parent e04aa2b13b
commit 572c938a55
1 changed files with 14 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

10
src/nix/flake-prefetch-inputs.cc
View file

@ -2,6 +2,7 @@
#include "nix/fetchers/fetch-to-store.hh"
#include "nix/util/thread-pool.hh"
#include "nix/store/filetransfer.hh"
#include "nix/util/exit.hh"
#include <nlohmann/json.hpp>
@ -35,16 +36,23 @@ struct CmdFlakePrefetchInputs : FlakeCommand
Sync<State> state_;
std::atomic<size_t> nrFailed{0};
std::function<void(const Node & node)> visit;
visit = [&](const Node & node) {
if (!state_.lock()->done.insert(&node).second)
return;
if (auto lockedNode = dynamic_cast<const LockedNode *>(&node)) {
try {
Activity act(*logger, lvlInfo, actUnknown, fmt("fetching '%s'", lockedNode->lockedRef));
auto accessor = lockedNode->lockedRef.input.getAccessor(store).first;
if (!evalSettings.lazyTrees)
fetchToStore(*store, accessor, FetchMode::Copy, lockedNode->lockedRef.input.getName());
} catch (Error & e) {
printError("%s", e.what());
nrFailed++;
}
}
for (auto & [inputName, input] : node.inputs) {
@ -56,6 +64,8 @@ struct CmdFlakePrefetchInputs : FlakeCommand
pool.enqueue(std::bind(visit, *flake.lockFile.root));
pool.process();
throw Exit(nrFailed ? 1 : 0);
}
};