self-review

server/reflector/hatchet/workflows/daily_multitrack_pipeline.py

@@ -559,7 +559,7 @@ async def generate_waveform(input: PipelineInput, ctx: Context) -> WaveformResul
 
 
 @daily_multitrack_pipeline.task(
-    parents=[mixdown_tracks],
+    parents=[process_tracks],
     execution_timeout=timedelta(seconds=TIMEOUT_HEAVY),
     retries=3,
 )

server/reflector/utils/webhook.py

@@ -13,6 +13,7 @@ from pydantic import BaseModel
 
 from reflector.logger import logger
 from reflector.settings import settings
+from reflector.utils.string import NonEmptyString
 from reflector.utils.webhook_outgoing_models import (
     WebhookCalendarEventPayload,
     WebhookParticipantPayload,
@@ -100,8 +101,8 @@ async def send_webhook_request(
 
 
 async def build_transcript_webhook_payload(
-    transcript_id: str,
+    transcript_id: NonEmptyString,
-    room_id: str,
+    room_id: NonEmptyString,
 ) -> WebhookPayload | None:
     """Build webhook payload by fetching transcript and room data from database."""
     # Inline imports required: this utils module would create circular imports
@@ -195,7 +196,9 @@ async def build_transcript_webhook_payload(
     )
 
 
-async def build_test_webhook_payload(room_id: str) -> WebhookTestPayload | None:
+async def build_test_webhook_payload(
+    room_id: NonEmptyString,
+) -> WebhookTestPayload | None:
     """Build test webhook payload."""
     # Inline import: avoid circular dependency (utils -> db -> utils)
     from reflector.db.rooms import rooms_controller  # noqa: PLC0415

server/reflector/worker/webhook.py

@@ -142,7 +142,6 @@ async def test_webhook(room_id: str) -> dict:
 
         payload_bytes = _serialize_payload(payload)
 
-        # Build headers with signature
         headers = build_webhook_headers(
             event_type="test",
             payload_bytes=payload_bytes,