Skip to content

Commit

Permalink
Always retry chained docker image pull
Browse files Browse the repository at this point in the history
Without unused "error" argument retry does not happens.

Fixes: c437f3b ("Cosmetics")
  • Loading branch information
koct9i committed May 24, 2024
1 parent 545f78f commit c7dc862
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion yt/yt/library/containers/cri/cri_executor.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -592,8 +592,10 @@ class TCriExecutor
auto guard = Guard(SpinLock_);
if (auto* pullFuture = InflightImagePulls_.FindPtr(image.Image)) {
YT_LOG_DEBUG("Waiting for in-flight docker image pull (Image: %v)", image);
return pullFuture->ToImmediatelyCancelable().Apply(BIND([=, this, this_ = MakeStrong(this)] {
return pullFuture->ToImmediatelyCancelable()
.Apply(BIND([=, this, this_ = MakeStrong(this)] (const TError& error) {
// Ignore errors and retry pull after end of previous concurrent attempt.
Y_UNUSED(error);
return PullImage(image, /*always*/ false, authConfig, podSpec);
}));
}
Expand Down

0 comments on commit c7dc862

Please sign in to comment.