diff --git a/x-pack/platform/plugins/shared/streams/server/lib/tasks/task_definitions/features_identification.ts b/x-pack/platform/plugins/shared/streams/server/lib/tasks/task_definitions/features_identification.ts
index 1e082c5cac1be..b4d9dff0e45d6 100644
--- a/x-pack/platform/plugins/shared/streams/server/lib/tasks/task_definitions/features_identification.ts
+++ b/x-pack/platform/plugins/shared/streams/server/lib/tasks/task_definitions/features_identification.ts
@@ -24,6 +24,7 @@ import type { TaskParams } from '../types';
 import { PromptsConfigService } from '../../saved_objects/significant_events/prompts_config_service';
 import { cancellableTask } from '../cancellable_task';
 import { MAX_FEATURE_AGE_MS } from '../../streams/feature/feature_client';
+import { isDefinitionNotFoundError } from '../../streams/errors/definition_not_found_error';
 
 export interface FeaturesIdentificationTaskParams {
   connectorId: string;
@@ -144,6 +145,13 @@ export function createStreamsFeaturesIdentificationTask(taskContext: TaskContext
                   { features }
                 );
               } catch (error) {
+                if (isDefinitionNotFoundError(error)) {
+                  taskContext.logger.debug(
+                    `Stream ${streamName} was deleted before features identification task started, skipping`
+                  );
+                  return getDeleteTaskRunResult();
+                }
+
                 // Get connector info for error enrichment
                 const connector = await inferenceClient.getConnectorById(connectorId);
 
diff --git a/x-pack/platform/plugins/shared/streams/server/lib/tasks/task_definitions/significant_events_queries_generation.ts b/x-pack/platform/plugins/shared/streams/server/lib/tasks/task_definitions/significant_events_queries_generation.ts
index 4cad0fe7c7170..980b80e9e4378 100644
--- a/x-pack/platform/plugins/shared/streams/server/lib/tasks/task_definitions/significant_events_queries_generation.ts
+++ b/x-pack/platform/plugins/shared/streams/server/lib/tasks/task_definitions/significant_events_queries_generation.ts
@@ -22,6 +22,7 @@ import type { TaskParams } from '../types';
 import { PromptsConfigService } from '../../saved_objects/significant_events/prompts_config_service';
 import { cancellableTask } from '../cancellable_task';
 import { generateSignificantEventDefinitions } from '../../significant_events/generate_significant_events';
+import { isDefinitionNotFoundError } from '../../streams/errors/definition_not_found_error';
 
 export interface SignificantEventsQueriesGenerationTaskParams {
   connectorId: string;
@@ -153,6 +154,13 @@ export function createStreamsSignificantEventsQueriesGenerationTask(taskContext:
                   combinedResults
                 );
               } catch (error) {
+                if (isDefinitionNotFoundError(error)) {
+                  taskContext.logger.debug(
+                    `Stream ${streamName} was deleted before significant events queries generation task started, skipping`
+                  );
+                  return getDeleteTaskRunResult();
+                }
+
                 // Get connector info for error enrichment
                 const connector = await inferenceClient.getConnectorById(connectorId);