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.
Ancestors
- builtins.tuple
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(value, names=None, *, module=None, qualname=None, type=None, start=1):
Machine-readable reason for the message to have been triggered.
Variables
- static
LIMITS_EXCEEDED
- static
MODELLER_TIMEOUT
- static
NO_DATA
- static
NO_NEW_DATA
- static
WORKER_ERROR
TaskAbortBody
class TaskAbortBody(*args, **kwargs):
Body of a TASK_ABORT message.
Ancestors
- builtins.dict
Variables
- static
message : Optional[str]
- static
reason : Optional[Literal['WORKER_ERROR', 'NO_NEW_DATA', 'MODELLER_TIMEOUT', 'NO_DATA', 'LIMITS_EXCEEDED']]