Function store_event

app/deploy/jockey/worker/queue.py:265–289

Store a task event in Redis using sorted sets for timestamp-based queries. Args: task_id: Task identifier event: Event to store

(task_id: str, event: BaseEvent)

def store_event(task_id: str, event: BaseEvent) -> None:
    """Store a task event in Redis using sorted sets for timestamp-based queries.

    Args:
        task_id: Task identifier
        event: Event to store
    """
    # Get task data to find namespace and project_id
    task_data = get_task_data(task_id)
    if not task_data:
        logger.error(f"Cannot store event for task {task_id}: task not found")
        return

    timestamp = datetime.now(UTC)
    data: EventData = {
        "namespace": task_data["namespace"],
        "project_id": task_data["project_id"],
        "timestamp": timestamp.isoformat(),
        "event": event.serialize(),
    }

    _get_redis_client().zadd(
        _get_event_key(task_id),
        {json.dumps(data): timestamp.timestamp()},
    )


def get_task_status(task_id: str) -> Optional[BaseEvent]: