diff options
| author | Dan Engelbrecht <[email protected]> | 2026-04-13 19:17:09 +0200 |
|---|---|---|
| committer | GitHub Enterprise <[email protected]> | 2026-04-13 19:17:09 +0200 |
| commit | 3d59b5d7036c35fe484d052ff32dbdc9d0a75cf7 (patch) | |
| tree | 8d24babc8cd3d097800af0bd960c7ba1d72927d7 /src/zencompute/runners/remotehttprunner.cpp | |
| parent | use mimalloc by default (#952) (diff) | |
| download | zen-3d59b5d7036c35fe484d052ff32dbdc9d0a75cf7.tar.xz zen-3d59b5d7036c35fe484d052ff32dbdc9d0a75cf7.zip | |
fix utf characters in source code (#953)
Diffstat (limited to 'src/zencompute/runners/remotehttprunner.cpp')
| -rw-r--r-- | src/zencompute/runners/remotehttprunner.cpp | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/src/zencompute/runners/remotehttprunner.cpp b/src/zencompute/runners/remotehttprunner.cpp index 55f78fdd6..08f381b7f 100644 --- a/src/zencompute/runners/remotehttprunner.cpp +++ b/src/zencompute/runners/remotehttprunner.cpp @@ -263,7 +263,7 @@ RemoteHttpRunner::SubmitActions(const std::vector<Ref<RunnerAction>>& Actions) // Collect distinct QueueIds and ensure remote queues exist once per queue - std::unordered_map<int, Oid> QueueTokens; // QueueId → remote token (0 stays as Zero) + std::unordered_map<int, Oid> QueueTokens; // QueueId -> remote token (0 stays as Zero) for (const Ref<RunnerAction>& Action : Actions) { @@ -416,7 +416,7 @@ RemoteHttpRunner::SubmitAction(Ref<RunnerAction> Action) if (WorkResponseCode == HttpResponseCode::FailedDependency && Attempt == 0) { - ZEN_WARN("remote {} returned FailedDependency for action {} — re-registering worker and retrying", + ZEN_WARN("remote {} returned FailedDependency for action {} - re-registering worker and retrying", m_Http.GetBaseUri(), ActionId); @@ -437,7 +437,7 @@ RemoteHttpRunner::SubmitAction(Ref<RunnerAction> Action) if (WorkResponseCode == HttpResponseCode::FailedDependency && Attempt == 0) { - ZEN_WARN("remote {} returned FailedDependency for action {} — re-registering worker and retrying", + ZEN_WARN("remote {} returned FailedDependency for action {} - re-registering worker and retrying", m_Http.GetBaseUri(), ActionId); @@ -451,7 +451,7 @@ RemoteHttpRunner::SubmitAction(Ref<RunnerAction> Action) if (WorkResponseCode == HttpResponseCode::NotFound) { - // Remote needs attachments — resolve them and retry with a CbPackage + // Remote needs attachments - resolve them and retry with a CbPackage CbPackage Pkg; Pkg.SetObject(ActionObj); @@ -644,7 +644,7 @@ RemoteHttpRunner::SubmitActionBatch(const std::string& SubmitUrl, const std::vec } else { - ZEN_WARN("batch submit: missing attachment {} — falling back to individual submit", NeedHash); + ZEN_WARN("batch submit: missing attachment {} - falling back to individual submit", NeedHash); return FallbackToIndividualSubmit(Actions); } } @@ -656,16 +656,16 @@ RemoteHttpRunner::SubmitActionBatch(const std::string& SubmitUrl, const std::vec return ParseBatchResponse(RetryResponse, Actions); } - ZEN_WARN("batch submit retry failed with {} {} — falling back to individual submit", + ZEN_WARN("batch submit retry failed with {} {} - falling back to individual submit", (int)RetryResponse.StatusCode, ToString(RetryResponse.StatusCode)); return FallbackToIndividualSubmit(Actions); } } - // Unexpected status or connection error — fall back to individual submission + // Unexpected status or connection error - fall back to individual submission - ZEN_WARN("batch submit to {}{} failed — falling back to individual submit", m_Http.GetBaseUri(), SubmitUrl); + ZEN_WARN("batch submit to {}{} failed - falling back to individual submit", m_Http.GetBaseUri(), SubmitUrl); return FallbackToIndividualSubmit(Actions); } @@ -927,7 +927,7 @@ RemoteHttpRunner::MonitorThreadFunction() SweepOnce(); } - // Signal received — may be a WS wakeup or a quit signal + // Signal received - may be a WS wakeup or a quit signal SweepOnce(); } while (m_MonitorThreadEnabled); |