Test alerting demo

x-pack/plugins/task_manager/task_store.test.ts

@@ -51,12 +51,11 @@ describe('TaskStore', () => {
         maxAttempts: 2,
         supportedTypes: ['report', 'dernstraight', 'yawn'],
       });
-
       const result = await store.schedule(task);
 
-      sinon.assert.calledOnce(callCluster);
+      sinon.assert.calledTwice(callCluster);
 
-      return { result, callCluster, arg: callCluster.args[0][1] };
+      return { result, callCluster, arg: callCluster.args[1][1] };
     }
 
     test('serializes the params and state', async () => {
@@ -67,7 +66,6 @@ describe('TaskStore', () => {
       };
       const { callCluster, arg } = await testSchedule(task);
 
-      sinon.assert.calledOnce(callCluster);
       sinon.assert.calledWith(callCluster, 'index');
 
       expect(arg).toMatchObject({

x-pack/plugins/task_manager/task_store.ts

@@ -68,6 +68,7 @@ export class TaskStore {
   private index: string;
   private maxAttempts: number;
   private supportedTypes: string[];
+  private wasInitialized = false;
 
   /**
    * Constructs a new TaskStore.
@@ -88,43 +89,47 @@ export class TaskStore {
    * Initializes the store, ensuring the task manager index is created and up to date.
    */
   public async init() {
-    const properties = {
-      type: { type: 'keyword' },
-      task: {
-        properties: {
-          taskType: { type: 'keyword' },
-          runAt: { type: 'date' },
-          interval: { type: 'text' },
-          attempts: { type: 'integer' },
-          status: { type: 'keyword' },
-          params: { type: 'text' },
-          state: { type: 'text' },
-          user: { type: 'keyword' },
-          scope: { type: 'keyword' },
+    if (!this.wasInitialized) {
+      const properties = {
+        type: { type: 'keyword' },
+        task: {
+          properties: {
+            taskType: { type: 'keyword' },
+            runAt: { type: 'date' },
+            interval: { type: 'text' },
+            attempts: { type: 'integer' },
+            status: { type: 'keyword' },
+            params: { type: 'text' },
+            state: { type: 'text' },
+            user: { type: 'keyword' },
+            scope: { type: 'keyword' },
+          },
         },
-      },
-    };
-
-    try {
-      return await this.callCluster('indices.putTemplate', {
-        name: this.index,
-        body: {
-          index_patterns: [this.index],
-          mappings: {
-            _doc: {
-              dynamic: 'strict',
-              properties,
+      };
+
+      try {
+        return await this.callCluster('indices.putTemplate', {
+          name: this.index,
+          body: {
+            index_patterns: [this.index],
+            mappings: {
+              _doc: {
+                dynamic: 'strict',
+                properties,
+              },
+            },
+            settings: {
+              number_of_shards: 1,
+              auto_expand_replicas: '0-1',
             },
           },
-          settings: {
-            number_of_shards: 1,
-            auto_expand_replicas: '0-1',
-          },
-        },
-      });
-    } catch (err) {
-      throw err;
+        });
+      } catch (err) {
+        throw err;
+      }
+      this.wasInitialized = true;
     }
+    return;
   }
 
   /**
@@ -133,6 +138,7 @@ export class TaskStore {
    * @param task - The task being scheduled.
    */
   public async schedule(taskInstance: TaskInstance): Promise<ConcreteTaskInstance> {
+    await this.init();
     if (!this.supportedTypes.includes(taskInstance.taskType)) {
       throw new Error(`Unsupported task type "${taskInstance.taskType}".`);
     }