aboutsummaryrefslogtreecommitdiff
path: root/src/zencompute/runners/remotehttprunner.cpp
diff options
context:
space:
mode:
authorDan Engelbrecht <[email protected]>2026-04-13 19:17:09 +0200
committerGitHub Enterprise <[email protected]>2026-04-13 19:17:09 +0200
commit3d59b5d7036c35fe484d052ff32dbdc9d0a75cf7 (patch)
tree8d24babc8cd3d097800af0bd960c7ba1d72927d7 /src/zencompute/runners/remotehttprunner.cpp
parentuse mimalloc by default (#952) (diff)
downloadzen-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.cpp18
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);