fix status detailed flag

Author: dnsi0

docs/env.md

@@ -127,7 +127,7 @@ Environmental variables are also tracked in `ENVIRONMENT_VARIABLES` within `src/
 
 ## Compute
 
-- `C2D_DOWNLOAD_TIMEOUT`: Per-file timeout (in seconds) for downloading the algorithm and each input asset during a C2D job. If a download exceeds this timeout, the job fails instead of getting stuck. Defaults to `900` (15 minutes). Example: `900`
+- `C2D_DOWNLOAD_TIMEOUT`: Timeout (in seconds) for pulling the algorithm docker image during a C2D job. If the pull exceeds this timeout, the job fails with `PullImageFailed` instead of getting stuck. Defaults to `900` (15 minutes). Example: `900`
 
 The `DOCKER_COMPUTE_ENVIRONMENTS` environment variable is used to configure Docker-based compute environments in Ocean Node. This guide will walk you through the options available for defining `DOCKER_COMPUTE_ENVIRONMENTS` and how to set it up correctly. For configuring compute environments and setting prices for each resource (including pricing units and examples), see [Compute pricing](compute-pricing.md).
 

src/components/c2d/compute_engine_docker.ts

@@ -1695,7 +1695,7 @@ export class C2DEngineDocker extends C2DEngine {
     }
   }
 
-  private getDownloadTimeoutMs(): number {
+  private getImagePullTimeoutMs(): number {
     const raw = ENVIRONMENT_VARIABLES.C2D_DOWNLOAD_TIMEOUT.value
     const parsed = raw ? parseInt(raw, 10) : NaN
     if (Number.isFinite(parsed) && parsed > 0) {
@@ -1704,22 +1704,6 @@ export class C2DEngineDocker extends C2DEngine {
     return 15 * 60 * 1000
   }
 
-  private async pipelineWithDownloadTimeout(
-    source: NodeJS.ReadableStream,
-    destination: NodeJS.WritableStream
-  ): Promise<void> {
-    const timeoutMs = this.getDownloadTimeoutMs()
-    const controller = new AbortController()
-    const timer = setTimeout(() => {
-      controller.abort(new Error(`Download timed out after ${timeoutMs / 1000}s`))
-    }, timeoutMs)
-    try {
-      await pipeline(source, destination, { signal: controller.signal })
-    } finally {
-      clearTimeout(timer)
-    }
-  }
-
   // eslint-disable-next-line require-await
   private async processJob(job: DBComputeJob) {
     CORE_LOGGER.info(
@@ -2573,6 +2557,7 @@ export class C2DEngineDocker extends C2DEngine {
         )
       }
 
+      pullOptions.abortSignal = AbortSignal.timeout(this.getImagePullTimeoutMs())
       const pullStream = await this.docker.pull(job.containerImage, pullOptions)
       await new Promise((resolve, reject) => {
         let wroteStatusBanner = false
@@ -2909,7 +2894,7 @@ export class C2DEngineDocker extends C2DEngine {
         }
 
         if (storage) {
-          await this.pipelineWithDownloadTimeout(
+          await pipeline(
             (await storage.getReadableStream()).stream,
             createWriteStream(fullAlgoPath)
           )
@@ -3018,7 +3003,7 @@ export class C2DEngineDocker extends C2DEngine {
         const fullPath = jobFolderPath + '/data/inputs/' + fileInfo[0].name
         appendFileSync(configLogPath, `Downloading asset to ${fullPath}\n`)
         try {
-          await this.pipelineWithDownloadTimeout(
+          await pipeline(
             (await storage.getReadableStream()).stream,
             createWriteStream(fullPath)
           )

src/components/core/utils/statusHandler.ts

@@ -170,6 +170,9 @@ export async function status(
       CORE_LOGGER.log(LOG_LEVELS_STR.LEVEL_ERROR, `Error getting c2d clusters: ${error}`)
     }
     nodeStatus.supportedSchemas = typesenseSchemas.ddoSchemas
+  } else {
+    delete nodeStatus.c2dClusters
+    delete nodeStatus.supportedSchemas
   }
 
   if (config.persistentStorage) {