cancellation of interpreter execution

src/legacy/core_plugins/data/public/expressions/expressions_service.ts

@@ -41,6 +41,7 @@ export type getInitialContextFunction = () => InitialContextObject;
 export interface Handlers {
   getInitialContext: getInitialContextFunction;
   inspectorAdapters?: Adapters;
+  abortSignal?: AbortSignal;
 }
 
 type Context = object;

src/legacy/ui/public/vis/request_handlers/courier.js

@@ -42,7 +42,6 @@ const CourierRequestHandlerProvider = function () {
       inspectorAdapters,
       queryFilter
     }) {
-
       // Create a new search source that inherits the original search source
       // but has the appropriate timeRange applied via a filter.
       // This is a temporary solution until we properly pass down all required

src/plugins/data/common/expressions/create_error.ts

@@ -22,5 +22,6 @@ export const createError = (err: any) => ({
   error: {
     stack: process.env.NODE_ENV === 'production' ? undefined : err.stack,
     message: typeof err === 'string' ? err : err.message,
+    name: (err && err.name) || 'Error',
   },
 });

src/plugins/data/common/expressions/interpreter_provider.ts

@@ -71,8 +71,16 @@ export function interpreterProvider(config: any) {
       // if something failed, just return the failure
       if (getType(newContext) === 'error') return newContext;
 
+      // if execution was aborted return error
+      if (handlers.abortSignal && handlers.abortSignal.aborted) {
+        return createError({
+          message: 'The expression was aborted.',
+          name: 'AbortError',
+        });
+      }
+
       // Continue re-invoking chain until it's empty
-      return await invokeChain(chain, newContext);
+      return invokeChain(chain, newContext);
     } catch (e) {
       // Everything that throws from a function will hit this
       // The interpreter should *never* fail. It should always return a `{type: error}` on failure