jina.peapods.peas package

Submodules

• jina.peapods.peas.helper module

Module contents

class jina.peapods.peas.BasePea(args)

Bases: object

BasePea is a thread/process- container of BaseRuntime. It leverages threading.Thread or multiprocessing.Process to manage the lifecycle of a BaseRuntime object in a robust way.

A BasePea must be equipped with a proper Runtime class to work.

daemon

required here to set process/thread daemon

start()

Start the Pea. This method calls start() in threading.Thread or multiprocesssing.Process. .. #noqa: DAR201

join(*args, **kwargs)

Joins the Pea. This method calls join() in threading.Thread or multiprocesssing.Process.

Parameters

• args – extra positional arguments to pass to join

• kwargs – extra keyword arguments to pass to join

terminate()

Terminate the Pea. This method calls terminate() in threading.Thread or multiprocesssing.Process.

activate_runtime()

Send activate control message.

wait_start_success()

Block until all peas starts successfully.

If not success, it will raise an error hoping the outer function to catch it

close()

Close the Pea

This method makes sure that the Process/thread is properly finished and its resources properly released

Return type

None

property role

Get the role of this pea in a pod

Return type

PeaRoleType