[ML] Anomaly Detection: Adds never expire option to forecast creation modal

x-pack/plugins/ml/public/application/jobs/jobs_list/components/job_details/forecasts_table/forecasts_table.js

@@ -280,7 +280,14 @@ export class ForecastsTable extends Component {
         name: i18n.translate('xpack.ml.jobsList.jobDetails.forecastsTable.expiresLabel', {
           defaultMessage: 'Expires',
         }),
-        render: timeFormatter,
+        render: (value) => {
+          if (value === undefined) {
+            return i18n.translate('xpack.ml.jobsList.jobDetails.forecastsTable.neverExpiresLabel', {
+              defaultMessage: 'Never expires',
+            });
+          }
+          return timeFormatter(value);
+        },
         textOnly: true,
         sortable: true,
       },

x-pack/plugins/ml/public/application/services/forecast_service.ts

@@ -319,14 +319,15 @@ export function forecastServiceFactory(mlApi: MlApi) {
       );
   }
   // Runs a forecast
-  function runForecast(jobId: string, duration?: string) {
+  function runForecast(jobId: string, duration?: string, neverExpires?: boolean) {
     // eslint-disable-next-line no-console
     console.log('ML forecast service run forecast with duration:', duration);
     return new Promise((resolve, reject) => {
       mlApi
         .forecast({
           jobId,
           duration,
+          neverExpires,
         })
         .then((resp) => {
           resolve(resp);

x-pack/plugins/ml/public/application/services/ml_api_service/index.ts

@@ -355,9 +355,18 @@ export function mlApiProvider(httpService: HttpService) {
       });
     },
 
-    forecast({ jobId, duration }: { jobId: string; duration?: string }) {
+    forecast({
+      jobId,
+      duration,
+      neverExpires,
+    }: {
+      jobId: string;
+      duration?: string;
+      neverExpires?: boolean;
+    }) {
       const body = JSON.stringify({
         ...(duration !== undefined ? { duration } : {}),
+        ...(neverExpires === true ? { expires_in: '0' } : {}),
       });
 
       return httpService.http<any>({

x-pack/plugins/ml/public/application/timeseriesexplorer/components/forecasting_modal/forecasting_modal.js

@@ -49,6 +49,7 @@ function getDefaultState() {
     newForecastDuration: '1d',
     isNewForecastDurationValid: true,
     newForecastDurationErrors: [],
+    neverExpires: false,
     messages: [],
   };
 }
@@ -104,6 +105,12 @@ export class ForecastingModal extends Component {
     this.closeModal();
   };
 
+  onNeverExpiresChange = (event) => {
+    this.setState({
+      neverExpires: event.target.checked,
+    });
+  };
+
   onNewForecastDurationChange = (event) => {
     const newForecastDurationErrors = [];
     let isNewForecastDurationValid = true;
@@ -258,7 +265,7 @@ export class ForecastingModal extends Component {
     const durationInSeconds = parseInterval(this.state.newForecastDuration).asSeconds();
 
     this.mlForecastService
-      .runForecast(this.props.job.job_id, `${durationInSeconds}s`)
+      .runForecast(this.props.job.job_id, `${durationInSeconds}s`, this.state.neverExpires)
       .then((resp) => {
         // Endpoint will return { acknowledged:true, id: <now timestamp> } before forecast is complete.
         // So wait for results and then refresh the dashboard to the end of the forecast.
@@ -551,6 +558,8 @@ export class ForecastingModal extends Component {
             runForecast={this.checkJobStateAndRunForecast}
             newForecastDuration={this.state.newForecastDuration}
             onNewForecastDurationChange={this.onNewForecastDurationChange}
+            onNeverExpiresChange={this.onNeverExpiresChange}
+            neverExpires={this.state.neverExpires}
             isNewForecastDurationValid={this.state.isNewForecastDurationValid}
             newForecastDurationErrors={this.state.newForecastDurationErrors}
             isForecastRequested={this.state.isForecastRequested}

x-pack/plugins/ml/public/application/timeseriesexplorer/components/forecasting_modal/run_controls.js

@@ -20,6 +20,7 @@ import {
   EuiForm,
   EuiFormRow,
   EuiSpacer,
+  EuiSwitch,
   EuiText,
   EuiToolTip,
 } from '@elastic/eui';
@@ -82,6 +83,8 @@ export function RunControls({
   newForecastDuration,
   isNewForecastDurationValid,
   newForecastDurationErrors,
+  neverExpires,
+  onNeverExpiresChange,
   onNewForecastDurationChange,
   runForecast,
   isForecastRequested,
@@ -134,34 +137,60 @@ export function RunControls({
       <EuiSpacer size="s" />
       <EuiForm>
         <EuiFlexGroup>
-          <EuiFlexItem>
-            <EuiFormRow
-              label={
-                <FormattedMessage
-                  id="xpack.ml.timeSeriesExplorer.runControls.durationLabel"
-                  defaultMessage="Duration"
-                />
-              }
-              fullWidth
-              isInvalid={!isNewForecastDurationValid}
-              error={newForecastDurationErrors}
-              helpText={
-                <FormattedMessage
-                  id="xpack.ml.timeSeriesExplorer.runControls.forecastMaximumLengthHelpText"
-                  defaultMessage="Length of forecast, up to a maximum of {maximumForecastDurationDays} days.
+          <EuiFlexItem grow={false}>
+            <EuiFlexGroup direction="column">
+              <EuiFlexItem grow={false}>
+                <EuiFormRow
+                  label={
+                    <FormattedMessage
+                      id="xpack.ml.timeSeriesExplorer.runControls.durationLabel"
+                      defaultMessage="Duration"
+                    />
+                  }
+                  fullWidth
+                  isInvalid={!isNewForecastDurationValid}
+                  error={newForecastDurationErrors}
+                  helpText={
+                    <FormattedMessage
+                      id="xpack.ml.timeSeriesExplorer.runControls.forecastMaximumLengthHelpText"
+                      defaultMessage="Length of forecast, up to a maximum of {maximumForecastDurationDays} days.
                   Use s for seconds, m for minutes, h for hours, d for days, w for weeks."
-                  values={{ maximumForecastDurationDays: FORECAST_DURATION_MAX_DAYS }}
-                />
-              }
-            >
-              {disabledState.isDisabledToolTipText === undefined ? (
-                durationInput
-              ) : (
-                <EuiToolTip position="right" content={disabledState.isDisabledToolTipText}>
-                  {durationInput}
-                </EuiToolTip>
-              )}
-            </EuiFormRow>
+                      values={{ maximumForecastDurationDays: FORECAST_DURATION_MAX_DAYS }}
+                    />
+                  }
+                >
+                  {disabledState.isDisabledToolTipText === undefined ? (
+                    durationInput
+                  ) : (
+                    <EuiToolTip position="right" content={disabledState.isDisabledToolTipText}>
+                      {durationInput}
+                    </EuiToolTip>
+                  )}
+                </EuiFormRow>
+              </EuiFlexItem>
+              <EuiFlexItem grow={false}>
+                <EuiFormRow
+                  helpText={i18n.translate(
+                    'xpack.ml.timeSeriesExplorer.runControls.neverExpireHelpText',
+                    {
+                      defaultMessage:
+                        'When not selected, created forecasts will expire after 14 days.',
+                    }
+                  )}
+                >
+                  <EuiSwitch
+                    label={i18n.translate(
+                      'xpack.ml.timeSeriesExplorer.runControls.neverExpireLabel',
+                      {
+                        defaultMessage: 'Never expire',
+                      }
+                    )}
+                    checked={neverExpires}
+                    onChange={onNeverExpiresChange}
+                  />
+                </EuiFormRow>
+              </EuiFlexItem>
+            </EuiFlexGroup>
           </EuiFlexItem>
           <EuiFlexItem grow={false}>
             <EuiFormRow hasEmptyLabelSpace>
@@ -193,7 +222,9 @@ RunControls.propType = {
   newForecastDuration: PropTypes.string,
   isNewForecastDurationValid: PropTypes.bool,
   newForecastDurationErrors: PropTypes.array,
+  neverExpires: PropTypes.bool.isRequired,
   onNewForecastDurationChange: PropTypes.func.isRequired,
+  onNeverExpiresChange: PropTypes.func.isRequired,
   runForecast: PropTypes.func.isRequired,
   isForecastRequested: PropTypes.bool,
   forecastProgress: PropTypes.number,

x-pack/plugins/ml/server/routes/anomaly_detectors.ts

@@ -403,11 +403,10 @@ export function jobRoutes({ router, routeGuard }: RouteInitialization) {
       routeGuard.fullLicenseAPIGuard(async ({ mlClient, request, response }) => {
         try {
           const jobId = request.params.jobId;
-          const duration = request.body.duration;
           const body = await mlClient.forecast({
             job_id: jobId,
             body: {
-              duration,
+              ...request.body,
             },
           });
           return response.ok({

x-pack/plugins/ml/server/routes/schemas/anomaly_detectors_schema.ts

@@ -206,7 +206,10 @@ export const updateModelSnapshotBodySchema = schema.object({
   retain: schema.maybe(schema.boolean()),
 });
 
-export const forecastAnomalyDetector = schema.object({ duration: schema.any() });
+export const forecastAnomalyDetector = schema.object({
+  duration: schema.any(),
+  expires_in: schema.maybe(schema.any()),
+});
 
 export const forceQuerySchema = schema.object({
   force: schema.maybe(schema.boolean()),