types

Types related to transport layer sending and receiving.

Classes

CommunicationDetails

class CommunicationDetails(    mailbox_id: ForwardRef('str'),    pod_mailbox_ids: ForwardRef('dict[str, str]'),    task_id: ForwardRef('str'),):

Container for received communication details.

Variables

• mailbox_id : str - Alias for field number 0

• pod_mailbox_ids : dict[str, str] - Alias for field number 1

• task_id : str - Alias for field number 2

Reason

class Reason(*args, **kwds):

Machine-readable reason for the message to have been triggered.

Ancestors

• enum.Enum

Variables

• static DATA_NOT_AVAILABLE

• static LIMITS_EXCEEDED

• static MODELLER_TIMEOUT

• static NO_DATA

• static NO_NEW_DATA

• static TASK_COMPLETE_MODELLER_TIMEOUT

• static WORKER_ERROR

TaskAbortBody

class TaskAbortBody(*args, **kwargs):

Body of a TASK_ABORT message.

Variables

• static message : Optional[str]

• static reason : Optional[Literal['WORKER_ERROR', 'NO_NEW_DATA', 'MODELLER_TIMEOUT', 'NO_DATA', 'LIMITS_EXCEEDED', 'TASK_COMPLETE_MODELLER_TIMEOUT', 'DATA_NOT_AVAILABLE']]

---