jina.orchestrate.pods.helper module

class jina.orchestrate.pods.helper.ConditionalEvent(backend_runtime, events_list)[source]

Bases: object

ConditionalEvent provides a common interface to an event (multiprocessing or threading event) that gets triggered when any of the events provided in input is triggered (OR logic)

• Parameters

  • backend_runtime (RuntimeBackendType) – The runtime type to decide which type of Event to instantiate

  • events_list – The list of events that compose this composable event

jina.orchestrate.pods.helper.update_runtime_cls(args, copy=False)[source]

Get runtime_cls as a string from args

• Parameters

  • args – pod/deployment namespace args

  • copy – True if args shouldn’t be modified in-place

  Return type

  Namespace

  Returns

  runtime class as a string

jina.orchestrate.pods.helper.is_ready(address)[source]

TODO: make this async Check if status is ready. :type address: str :param address: the address where the control message needs to be sent :rtype: bool :return: True if status is ready else False.