[TS] type as string

js/src/client.ts

@@ -224,8 +224,8 @@
   inputs: KVMap;
   run_type: string;
   id?: string;
-  start_time?: number;
-  end_time?: number;
+  start_time?: number | string;
+  end_time?: number | string;
   extra?: KVMap;
   error?: string;
   serialized?: object;
@@ -1291,7 +1291,7 @@
     treeFilter?: string;
     isRoot?: boolean;
     dataSourceType?: string;
   }): Promise<any> {
     let projectIds_ = projectIds || [];
     if (projectNames) {
       projectIds_ = [
@@ -1579,7 +1579,7 @@
         `Failed to list shared examples: ${response.status} ${response.statusText}`
       );
     }
     return result.map((example: any) => ({
       ...example,
       _hostUrl: this.getHostUrl(),
     }));
@@ -2722,7 +2722,7 @@
     }
 
     const feedbackResult = await evaluator.evaluateRun(run_, referenceExample);
     const [_, feedbacks] = await this._logEvaluationFeedback(
       feedbackResult,
       run_,
       sourceInfo
@@ -3056,7 +3056,7 @@
   async _logEvaluationFeedback(
     evaluatorResponse: EvaluationResult | EvaluationResults,
     run?: Run,
     sourceInfo?: { [key: string]: any }
   ): Promise<[results: EvaluationResult[], feedbacks: Feedback[]]> {
     const evalResults: Array<EvaluationResult> =
       this._selectEvalResults(evaluatorResponse);
@@ -3095,7 +3095,7 @@
   public async logEvaluationFeedback(
     evaluatorResponse: EvaluationResult | EvaluationResults,
     run?: Run,
     sourceInfo?: { [key: string]: any }
   ): Promise<EvaluationResult[]> {
     const [results] = await this._logEvaluationFeedback(
       evaluatorResponse,
@@ -3363,7 +3363,7 @@
     promptIdentifier: string,
     like: boolean
   ): Promise<LikePromptResponse> {
     const [owner, promptName, _] = parsePromptIdentifier(promptIdentifier);
     const response = await this.caller.call(
       _getFetchImplementation(),
       `${this.apiUrl}/likes/${owner}/${promptName}`,
@@ -3468,7 +3468,7 @@
   }
 
   public async getPrompt(promptIdentifier: string): Promise<Prompt | null> {
     const [owner, promptName, _] = parsePromptIdentifier(promptIdentifier);
     const response = await this.caller.call(
       _getFetchImplementation(),
       `${this.apiUrl}/repos/${owner}/${promptName}`,
@@ -3512,7 +3512,7 @@
       );
     }
 
     const [owner, promptName, _] = parsePromptIdentifier(promptIdentifier);
     if (!(await this._currentTenantIsOwner(owner))) {
       throw await this._ownerConflictError("create a prompt", owner);
     }
@@ -3545,7 +3545,7 @@
 
   public async createCommit(
     promptIdentifier: string,
     object: any,
     options?: {
       parentCommitHash?: string;
     }
@@ -3554,7 +3554,7 @@
       throw new Error("Prompt does not exist, you must create it first.");
     }
 
     const [owner, promptName, _] = parsePromptIdentifier(promptIdentifier);
     const resolvedParentCommitHash =
       options?.parentCommitHash === "latest" || !options?.parentCommitHash
         ? await this._getLatestCommitHash(`${owner}/${promptName}`)

js/src/langchain.ts

@@ -71,7 +71,7 @@ export async function getLangchainCallbacks(
     if (!current || visited.has(current.id)) continue;
     visited.add(current.id);
 
-    runMap.set(current.id, current);
+    runMap.set(current.id, current as Run);
     if (current.child_runs) {
       queue.push(...current.child_runs);
     }

js/src/run_trees.ts

@@ -14,7 +14,7 @@ function stripNonAlphanumeric(input: string) {
 }
 
 export function convertToDottedOrderFormat(
-  epoch: number,
+  epoch: number | string,
   runId: string,
   executionOrder = 1
 ) {
@@ -154,8 +154,8 @@ export class RunTree implements BaseRun {
   project_name: string;
   parent_run?: RunTree;
   child_runs: RunTree[];
-  start_time: number;
-  end_time?: number;
+  start_time: number | string;
+  end_time?: number | string;
   extra: KVMap;
   tags?: string[];
   error?: string;

js/src/schemas.ts

@@ -75,13 +75,13 @@ export interface BaseRun {
   name: string;
 
   /** The epoch time at which the run started, if available. */
-  start_time?: number;
+  start_time?: number | string;
 
   /** Specifies the type of run (tool, chain, llm, etc.). */
   run_type: string;
 
   /** The epoch time at which the run ended, if applicable. */
-  end_time?: number;
+  end_time?: number | string;
 
   /** Any additional metadata or settings for the run. */
   extra?: KVMap;
@@ -148,6 +148,10 @@ export interface Run extends BaseRun {
   /** The ID of the project that owns this run. */
   session_id?: string;
 
+  start_time: string;
+
+  end_time?: string;
+
   /** IDs of any child runs spawned by this run. */
   child_run_ids?: string[];
 
@@ -199,7 +203,7 @@ export interface RunCreate extends BaseRun {
 
 export interface RunUpdate {
   id?: string;
-  end_time?: number;
+  end_time?: number | string;
   extra?: KVMap;
   tags?: string[];
   error?: string;
@@ -501,4 +505,10 @@ export interface RunWithAnnotationQueueInfo extends BaseRun {
 
   /** The time this run was added to the queue. */
   added_at?: string;
+
+  /** The ISO 8601 formatted string representing the start time of the run. */
+  start_time: string;
+
+  /** The ISO 8601 formatted string representing the end time of the run, if available. */
+  end_time?: string;
 }

js/src/tests/client.int.test.ts

@@ -490,6 +490,7 @@ test.concurrent(
       id: runId,
       name: "foo",
       run_type: "llm",
+      start_time: new Date().toISOString(),
       inputs: { input: "hello world" },
       outputs: { output: "hi there" },
     };