event

superduper.base.event

Source code

unpack_event

unpack_event(dict)

Parameter	Description
dict	Serialized event.

Helper function to deserialize event into Event class.

Job

Job(self,
     *,
     context: str,
     type_id: str,
     identifier: str,
     uuid: str,
     args: Sequence[Any] = (),
     kwargs: Dict = <factory>,
     time: datetime.datetime = <factory>,
     job_id: Optional[str] = <factory>,
     method: str,
     status: str = 'pending',
     dependencies: Sequence[str] = ()) -> None

Parameter	Description
context	context component for job creation
type_id	type_id of component
identifier	identifier of component
uuid	uuid of component
args	arguments of method
kwargs	kwargs of method
time	time of job creation
job_id	id of job
method	method to run
status	status of job
dependencies	list of job_id dependencies

Job event.

Event

Event(self) -> None

Event dataclass to store event data.

Create

Create(self,
     *,
     context: str,
     component: Dict,
     parent: str | None = None) -> None

Parameter	Description
context	the component context of creation.
component	the component to be created
parent	the parent of the component (if any)

Class for component creation events.

Signal

Signal(self,
     *,
     msg: str,
     context: str) -> None

Parameter	Description
msg	signal to send
context	the context of component creation

Event used to send a signal to the scheduler.

Change

Change(self,
     *,
     type: str,
     queue: str,
     ids: Sequence[str]) -> None

Parameter	Description
ids	list of ids detected in databackend. the ids affected
type	delete
queue	which table was affected

Class for streaming change events.