Skip to content

Commit ae2a294

Browse files
committed
wip: remove mentions to unused worker_id
1 parent 9b612bd commit ae2a294

4 files changed

Lines changed: 0 additions & 6 deletions

File tree

src/backend/core/recording/event/notification.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -224,7 +224,6 @@ def _notify_summary_service(recording):
224224
"sub": owner_access.user.sub,
225225
"room": recording.room.name,
226226
"language": recording.options.get("language"),
227-
"worker_id": recording.worker_id,
228227
"owner_timezone": str(owner_access.user.timezone),
229228
"download_link": f"{get_recording_download_base_url()}/{recording.id}",
230229
"context_language": owner_access.user.language,

src/summary/summary/api/route/tasks.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,6 @@ class TranscribeSummarizeTaskCreation(BaseModel):
2525
sub: str
2626
version: Optional[int] = 2
2727
room: Optional[str]
28-
worker_id: Optional[str]
2928
owner_timezone: Optional[str]
3029
language: Optional[str]
3130
download_link: Optional[str]
@@ -60,7 +59,6 @@ async def create_transcribe_summarize_task(request: TranscribeSummarizeTaskCreat
6059
request.sub,
6160
time.time(),
6261
request.room,
63-
request.worker_id,
6462
request.owner_timezone,
6563
request.language,
6664
request.download_link,

src/summary/summary/core/celery_worker.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -223,7 +223,6 @@ def process_audio_transcribe_summarize_v2(
223223
sub: str,
224224
received_at: float,
225225
room: str | None,
226-
worker_id: str | None,
227226
owner_timezone: str | None,
228227
language: str | None,
229228
download_link: str | None,
@@ -248,7 +247,6 @@ def process_audio_transcribe_summarize_v2(
248247
sub: OIDC subject identifier of the recording owner.
249248
received_at: Unix timestamp when the recording was received.
250249
room: room name where the recording took place.
251-
worker_id: LiveKit egress ID used to fetch the egress JSON from S3.
252250
owner_timezone: IANA timezone of the recording owner (e.g. "Europe/Paris").
253251
language: ISO 639-1 language code for transcription.
254252
download_link: URL to download the original recording.

src/summary/tests/api/test_api_tasks.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@ def test_create_task_returns_task_id(self, mock_time, mock_apply_async, client):
2424
"email": "user@example.com",
2525
"sub": "sub-123",
2626
"room": "room-abc",
27-
"worker_id": "EG_test123",
2827
"owner_timezone": "UTC",
2928
"language": None,
3029
"download_link": "https://example.com/file.mp4",

0 commit comments

Comments
 (0)