feat(sig): error tracking as a source (#51645)

Co-authored-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>
Co-authored-by: Michael Matloka <michael@matloka.com>

Author: 3 people

bin/start-rust-service

@@ -102,6 +102,8 @@ case "$RS_SVC" in
     export ALLOW_INTERNAL_IPS="true"
     export PERSONS_URL=postgres://posthog:posthog@localhost:5432/posthog_persons
     export ISSUE_BUCKETS_REDIS_URL=redis://localhost:6379
+    export SIGNALS_API_BASE_URL=http://localhost:8000 # Used to emit signals, via the internal API
+    export INTERNAL_API_SECRET=posthog123
     ;;
 
   embedding-worker)

frontend/src/queries/schema.json

@@ -118,6 +118,21 @@ export interface LinearIssueSignalInput {
     extra: LinearIssueSignalExtra
 }
 
+// Error tracking
+
+export interface ErrorTrackingSignalExtra {
+    fingerprint: string
+}
+
+export interface ErrorTrackingSignalInput {
+    source_type: 'issue_created' | 'issue_reopened' | 'issue_spiking'
+    source_product: 'error_tracking'
+    source_id: string
+    description: string
+    weight: number
+    extra: ErrorTrackingSignalExtra
+}
+
 // Discriminated union over all signal variants
 
 /** @discriminator source_product */
@@ -127,3 +142,4 @@ export type SignalInput =
     | ZendeskTicketSignalInput
     | GithubIssueSignalInput
     | LinearIssueSignalInput
+    | ErrorTrackingSignalInput

frontend/src/queries/schema/schema-signals.ts

@@ -48,6 +48,7 @@
 
 from products.early_access_features.backend.api import early_access_features
 from products.product_tours.backend.api import product_tours
+from products.signals.backend import views as signals_views
 from products.slack_app.backend.api import (
     posthog_code_event_handler,
     posthog_code_interactivity_handler,
@@ -247,6 +248,10 @@ def authorize_and_redirect(request: HttpRequest) -> HttpResponse:
         "api/projects/<str:team_id>/internal/hog_flows/user_blast_radius_persons",
         csrf_exempt(hog_flow.InternalHogFlowViewSet.as_view({"post": "internal_user_blast_radius_persons"})),
     ),
+    path(
+        "api/projects/<str:team_id>/internal/signals/emit",
+        csrf_exempt(signals_views.InternalSignalViewSet.as_view({"post": "emit"})),
+    ),
     # Test setup endpoint (only available in TEST mode)
     path("api/setup_test/<str:test_name>/", csrf_exempt(playwright_setup.setup_test)),
     re_path(r"^api.+", api_not_found),

posthog/schema.py

@@ -11,6 +11,7 @@
 from posthog.sync import database_sync_to_async
 from posthog.temporal.common.client import async_connect
 
+from products.signals.backend.models import SignalSourceConfig
 from products.signals.backend.temporal.buffer import BufferSignalsWorkflow
 from products.signals.backend.temporal.emitter import SignalEmitterInput, SignalEmitterWorkflow
 from products.signals.backend.temporal.types import BufferSignalsInput, EmitSignalInputs
@@ -60,6 +61,12 @@ async def emit_signal(
     if not organization.is_ai_data_processing_approved:
         return
 
+    is_enabled = await database_sync_to_async(SignalSourceConfig.is_source_enabled, thread_sensitive=False)(
+        team.id, source_product, source_type
+    )
+    if not is_enabled:
+        return
+
     token_count = len(_tiktoken_encoding.encode(description))
     if token_count > MAX_SIGNAL_DESCRIPTION_TOKENS:
         raise ValueError(

posthog/urls.py

@@ -0,0 +1,43 @@
+# Generated by Django 4.2.29 on 2026-03-19 15:14
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+    dependencies = [
+        ("signals", "0010_add_data_import_signal_source_choices"),
+    ]
+
+    operations = [
+        migrations.AlterField(
+            model_name="signalsourceconfig",
+            name="source_product",
+            field=models.CharField(
+                choices=[
+                    ("session_replay", "Session replay"),
+                    ("llm_analytics", "LLM analytics"),
+                    ("github", "GitHub"),
+                    ("linear", "Linear"),
+                    ("zendesk", "Zendesk"),
+                    ("error_tracking", "Error tracking"),
+                ],
+                max_length=100,
+            ),
+        ),
+        migrations.AlterField(
+            model_name="signalsourceconfig",
+            name="source_type",
+            field=models.CharField(
+                choices=[
+                    ("session_analysis_cluster", "Session analysis cluster"),
+                    ("evaluation", "Evaluation"),
+                    ("issue", "Issue"),
+                    ("ticket", "Ticket"),
+                    ("issue_created", "Issue created"),
+                    ("issue_reopened", "Issue reopened"),
+                    ("issue_spiking", "Issue spiking"),
+                ],
+                max_length=100,
+            ),
+        ),
+    ]

products/signals/backend/api.py

@@ -1 +1 @@
-0010_add_data_import_signal_source_choices
+0011_add_error_tracking_signal_types

products/signals/backend/migrations/0011_add_error_tracking_signal_types.py

@@ -13,12 +13,16 @@ class SourceProduct(models.TextChoices):
         GITHUB = "github", "GitHub"
         LINEAR = "linear", "Linear"
         ZENDESK = "zendesk", "Zendesk"
+        ERROR_TRACKING = "error_tracking", "Error tracking"
 
     class SourceType(models.TextChoices):
         SESSION_ANALYSIS_CLUSTER = "session_analysis_cluster", "Session analysis cluster"
         EVALUATION = "evaluation", "Evaluation"
         ISSUE = "issue", "Issue"
         TICKET = "ticket", "Ticket"
+        ISSUE_CREATED = "issue_created", "Issue created"
+        ISSUE_REOPENED = "issue_reopened", "Issue reopened"
+        ISSUE_SPIKING = "issue_spiking", "Issue spiking"
 
     team = models.ForeignKey("posthog.Team", on_delete=models.CASCADE, related_name="signal_source_configs")
     source_product = models.CharField(max_length=100, choices=SourceProduct.choices)
@@ -29,6 +33,23 @@ class SourceType(models.TextChoices):
     updated_at = models.DateTimeField(auto_now=True)
     created_by = models.ForeignKey("posthog.User", on_delete=models.SET_NULL, null=True, blank=True)
 
+    @classmethod
+    def is_source_enabled(cls, team_id: int, source_product: str, source_type: str) -> bool:
+        """Check whether a given signal source is enabled for a team.
+
+        LLM analytics signals are always allowed (gated in llma evals workflows). TODO - this should be moved here.
+        For everything else, the team must have a SignalSourceConfig row with enabled=True.
+        """
+        if source_product == cls.SourceProduct.LLM_ANALYTICS:
+            return True
+
+        return cls.objects.filter(
+            team_id=team_id,
+            source_product=source_product,
+            source_type=source_type,
+            enabled=True,
+        ).exists()
+
     class Meta:
         constraints = [
             models.UniqueConstraint(

products/signals/backend/migrations/max_migration.txt

@@ -5,6 +5,7 @@
 import temporalio.exceptions
 
 from products.signals.backend.api import emit_signal
+from products.signals.backend.models import SignalSourceConfig
 from products.signals.backend.temporal.buffer import BufferSignalsWorkflow
 from products.signals.backend.temporal.emitter import SignalEmitterWorkflow
 
@@ -83,7 +84,10 @@ async def test_emit_signal_accepts_valid_input(self, source_product, source_type
             AsyncMock(),  # emitter start
         ]
 
-        with patch("products.signals.backend.api.async_connect", return_value=client):
+        with (
+            patch("products.signals.backend.api.async_connect", return_value=client),
+            patch.object(SignalSourceConfig, "is_source_enabled", return_value=True),
+        ):
             await emit_signal(
                 team=team_stub,
                 source_product=source_product,
@@ -112,7 +116,10 @@ async def test_emit_signal_accepts_valid_input(self, source_product, source_type
     async def test_emit_signal_rejects_invalid_input(self, source_product, source_type, extra, team_stub):
         client = AsyncMock()
 
-        with patch("products.signals.backend.api.async_connect", return_value=client):
+        with (
+            patch("products.signals.backend.api.async_connect", return_value=client),
+            patch.object(SignalSourceConfig, "is_source_enabled", return_value=True),
+        ):
             with pytest.raises(pydantic.ValidationError):
                 await emit_signal(
                     team=team_stub,