Surface Export Errors

apps/zui/src/core/invoke.ts

@@ -4,5 +4,12 @@ export function invoke<K extends OperationName>(
   name: K,
   ...args: Parameters<Operations[K]>
 ): Promise<Awaited<ReturnType<Operations[K]>>> {
-  return global.zui.invoke(name, ...args)
+  return global.zui.invoke(name, ...args).catch((error) => {
+    throw new Error(
+      error
+        .toString()
+        // Here we are stripping the error prefix that electron tacks on.
+        .replace(`Error: Error invoking remote method '${name}': `, "")
+    )
+  })
 }

apps/zui/src/css/global/_forms.scss

@@ -37,6 +37,10 @@ select {
   background-repeat: no-repeat;
   background-size: 1.2em 1.2em;
   background-position: calc(100% - 10px) center;
+  field-sizing: content;
+  inline-size: auto;
+  max-inline-size: 100%;
+  padding-inline-end: 3em;
 }
 
 label {

apps/zui/src/domain/results/handlers/export.ts

@@ -44,7 +44,7 @@ export const exportToFile = createHandler(
       .promise(promise, {
         loading: "Exporting...",
         success: "Export Completed: " + filePath,
-        error: "Error Exporting",
+        error: (e) => e.message,
       })
       .catch((e) => {
         console.error(e)

apps/zui/src/domain/results/operations.ts

@@ -17,11 +17,16 @@ export const exportToFile = createOperation(
       controlMessages: false,
       timeout: Infinity,
     })
+
     try {
       await pipe(
         res.body as unknown as NodeJS.ReadableStream,
         fs.createWriteStream(outPath)
       )
+      const status = await lake.client.queryStatus(res.requestId)
+      if (status.error) {
+        throw new Error(status.error)
+      }
     } catch (e) {
       fs.unlink(outPath, () => {})
       throw e

packages/zed-js/src/client/base-client.ts

@@ -4,6 +4,7 @@ import { ResultStream } from '../query/result-stream';
 import { createError } from '../util/error';
 import * as Types from './types';
 import { accept, defaults, parseContent, toJS, wrapAbort } from './utils';
+import { decode } from '..';
 
 export abstract class BaseClient {
   public abstract fetch: Types.IsoFetch;
@@ -50,6 +51,15 @@ export abstract class BaseClient {
     return new ResultStream(result, abortCtl);
   }
 
+  async queryStatus(id: string) {
+    const response = await this.send({
+      method: 'GET',
+      path: `/query/status/${id}`,
+      contentType: 'application/json',
+    });
+    return decode(await response.json()).toJS();
+  }
+
   async describeQuery(
     query: string,
     options: { signal?: AbortSignal; timeout?: number; pool?: string } = {}

packages/zed-js/src/query/result-stream.ts

@@ -17,6 +17,10 @@ export class ResultStream extends EventEmitter {
     super();
   }
 
+  get requestId() {
+    return this.resp.headers.get('x-request-id');
+  }
+
   get body() {
     return this.resp.body;
   }