Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 10 additions & 0 deletions nuon/models/app_queue_emitter.py
Original file line number Diff line number Diff line change
Expand Up @@ -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):
Expand All @@ -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
Expand Down Expand Up @@ -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()
Expand Down Expand Up @@ -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:
Expand Down Expand Up @@ -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):
Expand Down Expand Up @@ -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,
Expand Down
9 changes: 9 additions & 0 deletions nuon/models/app_queue_signal.py
Original file line number Diff line number Diff line change
Expand Up @@ -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):
Expand All @@ -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
Expand All @@ -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
Expand Down Expand Up @@ -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:
Expand Down Expand Up @@ -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)
Expand Down Expand Up @@ -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,
Expand Down
2 changes: 1 addition & 1 deletion pyproject.toml
Original file line number Diff line number Diff line change
@@ -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"
Expand Down
2 changes: 1 addition & 1 deletion version.txt
Original file line number Diff line number Diff line change
@@ -1 +1 @@
0.19.968
0.19.970
Loading