Function execute

worker/src/components/core/artifact-writer.ts:160–235

({ inputs, params }, context)

    },
  },
  async execute({ inputs, params }, context) {
    const destinations: ('run' | 'library')[] = [];
    if (params.saveToRunArtifacts) {
      destinations.push('run');
    }
    if (params.publishToArtifactLibrary) {
      destinations.push('library');
    }

    // Resolve artifact name with dynamic placeholders
    const artifactNameTemplate = inputs.artifactName || '{{run_id}}-{{timestamp}}';
    const resolvedArtifactName = substituteArtifactName(artifactNameTemplate, {
      runId: context.runId,
      componentRef: context.componentRef,
    });

    // Build full filename with extension
    const extension = params.fileExtension || '.txt';
    const fileName = resolvedArtifactName.endsWith(extension)
      ? resolvedArtifactName
      : `${resolvedArtifactName}${extension}`;

    // Serialize content to string - if already a string, use as-is; otherwise JSON stringify
    const rawContent = inputs.content;
    let serializedContent: string;
    if (rawContent === undefined || rawContent === null) {
      serializedContent = '';
    } else if (typeof rawContent === 'string') {
      serializedContent = rawContent;
    } else {
      // Serialize arrays, objects, and other types to JSON
      serializedContent = JSON.stringify(rawContent, null, 2);
    }

    if (destinations.length === 0) {
      context.logger.info('[ArtifactWriter] No destinations selected; skipping upload.');
      return {
        artifactId: undefined,
        artifactName: resolvedArtifactName,
        fileName,
        size: Buffer.byteLength(serializedContent),
        destinations: [],
        saved: false,
      };
    }

    if (!context.artifacts) {
      throw new ConfigurationError(
        'Artifact service is not available in this execution environment. Ensure the worker is configured with artifact storage.',
        { configKey: 'artifacts' },
      );
    }

    const buffer = Buffer.from(serializedContent, 'utf-8');
    context.logger.info(
      `[ArtifactWriter] Uploading '${fileName}' (${buffer.byteLength} bytes) to ${destinations.join(
        ', ',
      )}`,