diff --git a/nuon/models/app_queue_emitter.py b/nuon/models/app_queue_emitter.py index 4ab108e4..e6bbca80 100644 --- a/nuon/models/app_queue_emitter.py +++ b/nuon/models/app_queue_emitter.py @@ -41,6 +41,8 @@ class AppQueueEmitter: org_id (str | Unset): queue_id (str | Unset): Many-to-one: each emitter belongs to exactly one queue scheduled_at (str | Unset): For scheduled mode: the time to fire the signal + signal_expires_in (int | Unset): Optional TTL for emitted signals. When set, each emitted signal's ExpiresAt + is computed as time.Now().Add(SignalExpiresIn) at emission time. signal_template (SignaldbSignalData | Unset): signal_type (str | Unset): Signal template - the signal to emit on each tick status (AppCompositeStatus | Unset): @@ -63,6 +65,7 @@ class AppQueueEmitter: org_id: str | Unset = UNSET queue_id: str | Unset = UNSET scheduled_at: str | Unset = UNSET + signal_expires_in: int | Unset = UNSET signal_template: SignaldbSignalData | Unset = UNSET signal_type: str | Unset = UNSET status: AppCompositeStatus | Unset = UNSET @@ -103,6 +106,8 @@ def to_dict(self) -> dict[str, Any]: scheduled_at = self.scheduled_at + signal_expires_in = self.signal_expires_in + signal_template: dict[str, Any] | Unset = UNSET if not isinstance(self.signal_template, Unset): signal_template = self.signal_template.to_dict() @@ -152,6 +157,8 @@ def to_dict(self) -> dict[str, Any]: field_dict["queue_id"] = queue_id if scheduled_at is not UNSET: field_dict["scheduled_at"] = scheduled_at + if signal_expires_in is not UNSET: + field_dict["signal_expires_in"] = signal_expires_in if signal_template is not UNSET: field_dict["signal_template"] = signal_template if signal_type is not UNSET: @@ -207,6 +214,8 @@ def from_dict(cls: type[T], src_dict: Mapping[str, Any]) -> T: scheduled_at = d.pop("scheduled_at", UNSET) + signal_expires_in = d.pop("signal_expires_in", UNSET) + _signal_template = d.pop("signal_template", UNSET) signal_template: SignaldbSignalData | Unset if isinstance(_signal_template, Unset): @@ -248,6 +257,7 @@ def from_dict(cls: type[T], src_dict: Mapping[str, Any]) -> T: org_id=org_id, queue_id=queue_id, scheduled_at=scheduled_at, + signal_expires_in=signal_expires_in, signal_template=signal_template, signal_type=signal_type, status=status, diff --git a/nuon/models/app_queue_signal.py b/nuon/models/app_queue_signal.py index a75e1eeb..71d83d3e 100644 --- a/nuon/models/app_queue_signal.py +++ b/nuon/models/app_queue_signal.py @@ -28,6 +28,7 @@ class AppQueueSignal: emitter_id (str | Unset): Optional: if this signal was emitted by an emitter enqueued (bool | Unset): execution_count (int | Unset): + expires_at (str | Unset): id (str | Unset): org_id (str | Unset): owner_id (str | Unset): @@ -47,6 +48,7 @@ class AppQueueSignal: emitter_id: str | Unset = UNSET enqueued: bool | Unset = UNSET execution_count: int | Unset = UNSET + expires_at: str | Unset = UNSET id: str | Unset = UNSET org_id: str | Unset = UNSET owner_id: str | Unset = UNSET @@ -72,6 +74,8 @@ def to_dict(self) -> dict[str, Any]: execution_count = self.execution_count + expires_at = self.expires_at + id = self.id org_id = self.org_id @@ -119,6 +123,8 @@ def to_dict(self) -> dict[str, Any]: field_dict["enqueued"] = enqueued if execution_count is not UNSET: field_dict["execution_count"] = execution_count + if expires_at is not UNSET: + field_dict["expires_at"] = expires_at if id is not UNSET: field_dict["id"] = id if org_id is not UNSET: @@ -165,6 +171,8 @@ def from_dict(cls: type[T], src_dict: Mapping[str, Any]) -> T: execution_count = d.pop("execution_count", UNSET) + expires_at = d.pop("expires_at", UNSET) + id = d.pop("id", UNSET) org_id = d.pop("org_id", UNSET) @@ -220,6 +228,7 @@ def from_dict(cls: type[T], src_dict: Mapping[str, Any]) -> T: emitter_id=emitter_id, enqueued=enqueued, execution_count=execution_count, + expires_at=expires_at, id=id, org_id=org_id, owner_id=owner_id, diff --git a/pyproject.toml b/pyproject.toml index 93f89e84..a9a97814 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -1,6 +1,6 @@ [project] name = "nuon" -version = "0.19.968" +version = "0.19.970" description = "A client library for accessing Nuon" authors = [] requires-python = ">=3.10" diff --git a/version.txt b/version.txt index 838b8ee3..6174320b 100644 --- a/version.txt +++ b/version.txt @@ -1 +1 @@ -0.19.968 +0.19.970