BaseEvent

​

Defining events

from bubus import BaseEvent

class FooCreateEvent(BaseEvent[str]):
    id: str | None = None
    name: str
    age: int

import { BaseEvent } from 'bubus'
import { z } from 'zod'

const FooCreateEvent = BaseEvent.extend('FooCreateEvent', {
  id: z.string().nullable().optional(),
  name: z.string(),
  age: z.number(),
  event_result_type: z.string(),
})

​

Core metadata fields

• event_id: unique UUIDv7
• event_type: event name/type key
• event_version: payload version marker
• event_result_type: expected handler return schema/type
• event_timeout: per-event timeout override
• event_handler_timeout: per-handler timeout cap override
• event_handler_slow_timeout: per-handler slow warning threshold
• event_concurrency: event scheduling mode override
• event_handler_concurrency: handler scheduling mode override
• event_handler_completion: handler completion strategy override

​

Runtime fields

• event_status: pending/started/completed
• event_created_at, event_started_at, event_completed_at
• event_parent_id: parent event link
• event_path: buses traversed
• event_results: per-handler result entries
• Child-event tracking (event_children/descendants)

​

Completion model

pending = bus.emit(MyEvent())
completed = await pending
value = await completed.event_result()

const pending = bus.emit(MyEvent({}))
const completed = await pending.done()
const value = completed.event_result

​

Result access helpers

​

first()

value = await event.first()
# equivalent: await event.event_result(...) with first-completion mode

const value = await event.first()

​

All results

by_handler = await event.event_results_by_handler_id()
items = await event.event_results_list()
flat_dict = await event.event_results_flat_dict(raise_if_conflicts=False)
flat_list = await event.event_results_flat_list()

const all = event.all_results
const first = event.event_result
const last = event.last_result
const errors = event.event_errors

​

reset()

fresh = event.reset()

const fresh = event.reset()

​

Serialization

payload = event.model_dump(mode='json')
restored = type(event).model_validate(payload)

const payload = event.toJSON()
const restored = BaseEvent.fromJSON(payload)

​

Notes

• Keep custom payload field names away from event_* reserved metadata names.
• event_result_type drives handler return validation in both runtimes.
• Parent-child tracking is automatic when events are emitted from handlers.