chore(aci): add default workflow to match default rule (#87207)

Author: cathteng

src/sentry/receivers/rules.py

@@ -1,10 +1,14 @@
 import logging
 
+from django.db import router, transaction
+
+from sentry import features
 from sentry.models.project import Project
 from sentry.models.rule import Rule
 from sentry.notifications.types import FallthroughChoiceType
 from sentry.signals import alert_rule_created, project_created
 from sentry.users.services.user.model import RpcUser
+from sentry.workflow_engine.migration_helpers.issue_alert_migration import IssueAlertMigrator
 
 logger = logging.getLogger("sentry")
 
@@ -36,7 +40,18 @@ def create_default_rules(project: Project, default_rules=True, RuleModel=Rule, *
         return
 
     rule_data = DEFAULT_RULE_DATA
-    rule = RuleModel.objects.create(project=project, label=DEFAULT_RULE_LABEL, data=rule_data)
+
+    with transaction.atomic(router.db_for_write(RuleModel)):
+        rule = RuleModel.objects.create(project=project, label=DEFAULT_RULE_LABEL, data=rule_data)
+
+        if features.has(
+            "organizations:workflow-engine-issue-alert-dual-write", project.organization
+        ):
+            workflow = IssueAlertMigrator(rule).run()
+            logger.info(
+                "workflow_engine.default_issue_alert.migrated",
+                extra={"rule_id": rule.id, "workflow_id": workflow.id},
+            )
 
     try:
         user: RpcUser = project.organization.get_default_owner()

tests/sentry/receivers/test_onboarding.py

@@ -15,6 +15,7 @@
 from sentry.models.project import Project
 from sentry.models.rule import Rule
 from sentry.organizations.services.organization import organization_service
+from sentry.receivers.rules import DEFAULT_RULE_LABEL
 from sentry.signals import (
     alert_rule_created,
     event_processed,
@@ -30,10 +31,12 @@
 from sentry.silo.base import SiloMode
 from sentry.testutils.cases import TestCase
 from sentry.testutils.helpers.datetime import before_now
+from sentry.testutils.helpers.features import with_feature
 from sentry.testutils.outbox import outbox_runner
 from sentry.testutils.silo import assume_test_silo_mode
 from sentry.testutils.skips import requires_snuba
 from sentry.utils.samples import load_data
+from sentry.workflow_engine.models import Workflow
 
 pytestmark = [requires_snuba]
 
@@ -138,6 +141,23 @@ def test_project_created(self):
         )
         assert task is not None
 
+    def test_project_created__default_rule(self):
+        project = self.create_project()
+        project_created.send(project=project, user=self.user, sender=type(project))
+
+        assert Rule.objects.filter(project=project).exists()
+        assert not Workflow.objects.filter(organization=project.organization).exists()
+
+    @with_feature("organizations:workflow-engine-issue-alert-dual-write")
+    def test_project_created__default_workflow(self):
+        project = self.create_project()
+        project_created.send(project=project, user=self.user, sender=type(project))
+
+        assert Rule.objects.filter(project=project).exists()
+        assert Workflow.objects.filter(
+            organization=project.organization, name=DEFAULT_RULE_LABEL
+        ).exists()
+
     @patch("sentry.analytics.record")
     def test_project_created_with_origin(self, record_analytics):
         project = self.create_project()