Function dispatch_webhooks

apps/api/src/services/webhooks/dispatch.py:73–98

Public entry point. Schedules webhook delivery as a background task. Args: event_name: The event that occurred (e.g. "course_completed"). org_id: The organization where the event happened. data: Event-specific payload data. webhook_ids: If provided, only del

(
    event_name: str,
    org_id: int,
    data: dict,
    webhook_ids: Optional[List[int]] = None,
)

async def dispatch_webhooks(
    event_name: str,
    org_id: int,
    data: dict,
    webhook_ids: Optional[List[int]] = None,
) -> None:
    """
    Public entry point. Schedules webhook delivery as a background task.

    Args:
        event_name: The event that occurred (e.g. "course_completed").
        org_id: The organization where the event happened.
        data: Event-specific payload data.
        webhook_ids: If provided, only deliver to these specific endpoints
                     (used by the test/ping feature).
    """
    validate_event_data(event_name, data)
    task = asyncio.create_task(
        _deliver_webhooks(event_name, org_id, data, webhook_ids)
    )
    _background_tasks.add(task)
    task.add_done_callback(_background_tasks.discard)
    task.add_done_callback(
        lambda t: logger.error("Webhook delivery batch failed: %s", t.exception())
        if not t.cancelled() and t.exception() else None
    )


async def _deliver_webhooks(