Remove ESQueue and replace with Task Manager queueing

x-pack/plugins/reporting/kibana.json

@@ -13,6 +13,7 @@
     "management",
     "licensing",
     "uiActions",
+    "taskManager",
     "embeddable",
     "share"
   ],

x-pack/plugins/reporting/server/core.ts

@@ -20,26 +20,25 @@ import { SecurityPluginSetup } from '../../security/server';
 import { ScreenshotsObservableFn } from '../server/types';
 import { ReportingConfig } from './';
 import { HeadlessChromiumDriverFactory } from './browsers/chromium/driver_factory';
+import { checkLicense, getExportTypesRegistry, ReportingTask } from './lib';
 import { screenshotsObservableFactory } from './lib/screenshots';
-import { checkLicense, getExportTypesRegistry } from './lib';
-import { ESQueueInstance } from './lib/create_queue';
-import { EnqueueJobFn } from './lib/enqueue_job';
 import { ReportingStore } from './lib/store';
+import { SchedulingFn } from './lib/task';
 
 export interface ReportingInternalSetup {
   elasticsearch: ElasticsearchServiceSetup;
   licensing: LicensingPluginSetup;
   basePath: BasePath['get'];
   router: IRouter;
   security?: SecurityPluginSetup;
+  task: ReportingTask;
 }
 
 export interface ReportingInternalStart {
   browserDriverFactory: HeadlessChromiumDriverFactory;
-  enqueueJob: EnqueueJobFn;
-  esqueue: ESQueueInstance;
   store: ReportingStore;
   savedObjects: SavedObjectsServiceStart;
+  scheduleTask: SchedulingFn;
   uiSettings: UiSettingsServiceStart;
 }
 
@@ -115,7 +114,7 @@ export class ReportingCore {
   /*
    * Gives async access to the startDeps
    */
-  private async getPluginStartDeps() {
+  public async getPluginStartDeps() {
     if (this.pluginStartDeps) {
       return this.pluginStartDeps;
     }
@@ -127,12 +126,8 @@ export class ReportingCore {
     return this.exportTypesRegistry;
   }
 
-  public async getEsqueue() {
-    return (await this.getPluginStartDeps()).esqueue;
-  }
-
-  public async getEnqueueJob() {
-    return (await this.getPluginStartDeps()).enqueueJob;
+  public async getTaskScheduler() {
+    return (await this.getPluginStartDeps()).scheduleTask;
   }
 
   public async getLicenseInfo() {

x-pack/plugins/reporting/server/export_types/csv_from_savedobject/execute_job.ts

@@ -10,7 +10,6 @@ import { CONTENT_TYPE_CSV, CSV_FROM_SAVEDOBJECT_JOB_TYPE } from '../../../common
 import { RunTaskFnFactory, ScheduledTaskParams, TaskRunResult } from '../../types';
 import { createGenerateCsv } from '../csv/generate_csv';
 import { JobParamsPanelCsv, SearchPanel } from './types';
-import { getFakeRequest } from './lib/get_fake_request';
 import { getGenerateCsvParams } from './lib/get_csv_job';
 
 /*
@@ -42,21 +41,12 @@ export const runTaskFnFactory: RunTaskFnFactory<ImmediateExecuteFn> = function e
     // jobID is only for "queued" jobs
     // Use the jobID as a logging tag or "immediate"
     const { jobParams } = jobPayload;
-    const jobLogger = logger.clone([jobId === null ? 'immediate' : jobId]);
+    const jobLogger = logger.clone(['immediate']);
     const generateCsv = createGenerateCsv(jobLogger);
-    const { isImmediate, panel, visType } = jobParams as JobParamsPanelCsv & {
-      panel: SearchPanel;
-    };
+    const { panel, visType } = jobParams as JobParamsPanelCsv & { panel: SearchPanel };
 
     jobLogger.debug(`Execute job generating [${visType}] csv`);
 
-    if (isImmediate && req) {
-      jobLogger.info(`Executing job from Immediate API using request context`);
-    } else {
-      jobLogger.info(`Executing job async using encrypted headers`);
-      req = await getFakeRequest(jobPayload, config.get('encryptionKey')!, jobLogger);
-    }
-
     const savedObjectsClient = context.core.savedObjects.client;
 
     const uiConfig = await reporting.getUiSettingsServiceFactory(savedObjectsClient);