errors

Author: pavelgj

genkit-tools/common/src/types/model.ts

@@ -57,6 +57,7 @@ export const OperationSchema = z.object({
   id: z.string(),
   done: z.boolean().optional(),
   output: z.any().optional(),
+  error: z.object({message: z.string()}).passthrough().optional(),
   metadata: z.record(z.string(), z.any()).optional(),
 });
 

genkit-tools/genkit-schema.json

@@ -1075,6 +1075,18 @@
           "type": "boolean"
         },
         "output": {},
+        "error": {
+          "type": "object",
+          "properties": {
+            "message": {
+              "type": "string"
+            }
+          },
+          "required": [
+            "message"
+          ],
+          "additionalProperties": true
+        },
         "metadata": {
           "type": "object",
           "additionalProperties": {}

js/core/src/background-action.ts

@@ -30,6 +30,7 @@ export const OperationSchema = z.object({
   id: z.string(),
   done: z.boolean().optional(),
   output: z.any().optional(),
+  error: z.object({ message: z.string() }).passthrough().optional(),
   metadata: z.record(z.string(), z.any()).optional(),
 });
 
@@ -41,6 +42,7 @@ export interface Operation<O = any> {
   id: string;
   done?: boolean;
   output?: O;
+  error?: { message: string; [key: string]: unknown };
   metadata?: Record<string, any>;
 }
 

js/plugins/googleai/src/predict.ts

@@ -21,6 +21,9 @@ export type PredictMethod = 'predict' | 'predictLongRunning';
 export interface Operation {
   name: string;
   done?: boolean;
+  error?: {
+    message: string;
+  },
   response?: {
     generateVideoResponse: {
       generatedSamples: { video: { uri: string } }[];

js/plugins/googleai/src/veo.ts

@@ -178,6 +178,11 @@ function toGenkitOp(apiOp: ApiOperation): Operation<GenerateResponseData> {
   if (apiOp.done !== undefined) {
     res.done = apiOp.done;
   }
+
+  if (apiOp.error) {
+    res.error = { message: apiOp.error.message };
+  }
+
   if (
     apiOp.response &&
     apiOp.response.generateVideoResponse &&

py/packages/genkit/src/genkit/core/typing.py

@@ -288,6 +288,13 @@ class ModelInfo(BaseModel):
     stage: Stage | None = None
 
 
+class Error(BaseModel):
+    """Model for error data."""
+
+    model_config = ConfigDict(extra='forbid', populate_by_name=True)
+    message: str
+
+
 class Operation(BaseModel):
     """Model for operation data."""
 
@@ -296,6 +303,7 @@ class Operation(BaseModel):
     id: str
     done: bool | None = None
     output: Any | None = None
+    error: Error | None = None
     metadata: dict[str, Any] | None = None