fix(v02): widen device-pod job output visibility
This commit is contained in:
@@ -142,7 +142,7 @@ test("device pod executor lists and isolates multiple logical device pods", asyn
|
||||
});
|
||||
|
||||
test("device-pod executor bounds gateway output text", async () => {
|
||||
const longText = "z".repeat(25000);
|
||||
const longText = "z".repeat(65000);
|
||||
const cloudApi = createServer(async (request, response) => {
|
||||
const body = await requestJson(request);
|
||||
response.writeHead(200, { "content-type": "application/json; charset=utf-8" });
|
||||
@@ -184,11 +184,11 @@ test("device-pod executor bounds gateway output text", async () => {
|
||||
});
|
||||
assert.equal(jobResponse.status, 202);
|
||||
const output = await waitForJobStatus(service.port, "device-pod-test", "job_bounded_output_test", "completed");
|
||||
assert.equal(output.output.text.length, 24000);
|
||||
assert.equal(output.text.length, 24000);
|
||||
assert.equal(output.bytes, 24000);
|
||||
assert.equal(output.output.text.length, 64000);
|
||||
assert.equal(output.text.length, 64000);
|
||||
assert.equal(output.bytes, 64000);
|
||||
assert.equal(output.truncation.truncated, true);
|
||||
assert.equal(output.truncation.originalBytes, 25000);
|
||||
assert.equal(output.truncation.originalBytes, 65000);
|
||||
assert.equal(output.output.omitted.reason, "device_job_output_truncated");
|
||||
assert.equal(JSON.stringify(output).includes(longText), false);
|
||||
} finally {
|
||||
|
||||
@@ -15,7 +15,7 @@ const environment = process.env.HWLAB_ENVIRONMENT || process.env.HWLAB_GITOPS_PR
|
||||
const cloudApiInternalUrl = normalizeBaseUrl(process.env.HWLAB_CLOUD_API_INTERNAL_URL || process.env.HWLAB_CLOUD_API_URL);
|
||||
const internalToken = textOr(process.env.HWLAB_DEVICE_POD_INTERNAL_TOKEN, "");
|
||||
const dispatchTimeoutMs = numberOr(process.env.HWLAB_DEVICE_POD_GATEWAY_DISPATCH_TIMEOUT_MS, 120000);
|
||||
const DEVICE_JOB_OUTPUT_MAX_BYTES = 24000;
|
||||
const DEVICE_JOB_OUTPUT_MAX_BYTES = 64000;
|
||||
const jobs = new Map();
|
||||
|
||||
listen(createServer(async (request, response) => {
|
||||
|
||||
Reference in New Issue
Block a user