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 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']]