diff --git a/server/reflector/hatchet/workflows/daily_multitrack_pipeline.py b/server/reflector/hatchet/workflows/daily_multitrack_pipeline.py index a201c3d1..b9dced5c 100644 --- a/server/reflector/hatchet/workflows/daily_multitrack_pipeline.py +++ b/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, ) diff --git a/server/reflector/utils/webhook.py b/server/reflector/utils/webhook.py index 6afdf18c..3290e80a 100644 --- a/server/reflector/utils/webhook.py +++ b/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, - room_id: str, + transcript_id: NonEmptyString, + 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 diff --git a/server/reflector/worker/webhook.py b/server/reflector/worker/webhook.py index 98af3e2f..2fcc95cf 100644 --- a/server/reflector/worker/webhook.py +++ b/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,