jina.peapods.peas.helper module

class jina.peapods.peas.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.peapods.peas.helper.update_runtime_cls(args, copy=False)[source]

Get runtime_cls as a string from args

Parameters

  • args – pea/pod namespace args

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

Return type

Namespace

Returns

runtime class as a string