Skip to main content

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.

Ancestors​

Variables​

  • 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.

Ancestors​

  • builtins.dict

Variables​

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