Object

Each created pipeline can be accessed in a dictionary at the pyot.conf.pipeline module. The key of the pipeline is the name provided in the configuration, if the pipeline is set as default, model name can be used aswell.

from pyot.conf.pipeline import pipelines

lol_pipeline = pipelines["lol"]

class Pipeline

Definitions:

• __init__

  • model: str

    Model of belonging.

  • name: str

    Name of pipeline.

  • stores: List[Store]

    List of Stores to add on the pipeline.

• __iter__

  Iterates over stores.

• __getitem__

  Get store by index.

Attributes:

• model: str

• name: str

• stores: List[StoreObject]

• sessions: ResourceTemplate[aiohttp.ClientSession]

Methods:

• async get -> Any

  • token: PipelineToken

    Token identifying the data, created by token() on Pyot Core objects.

• async set -> None

  • token: PipelineToken

    Token identifying the data, created by token() on Pyot Core objects.

  • value: Any

    Data to be stored in qualified stores.

  • stop: Store = None

    The instance of the store that it should stop at (not sink further).

• async post -> Any

  • token: PipelineToken

    Token identifying the data, created by token() on Pyot Core objects.

  • body -> Any

    Body of the request.

• async put -> Any

  • token: PipelineToken

    Token identifying the data, created by token() on Pyot Core objects.

  • body -> Any

    Body of the request.

• async clear -> None

  Clear data in all stores.

• async expire -> None

  Expire data in all the stores, used for stores that cannot automatically expire data on its own.

• async delete -> None

  • token: PipelineToken

    Token identifying the data, created by token() on Pyot Core objects.

• async contains -> bool

  • token: PipelineToken

    Token identifying the data, created by token() on Pyot Core objects.

Example

from pyot.conf.pipeline import pipelines
from pyot.utils.runners import loop_run

async def clear_cache_lol():
    lol_pipeline = pipelines["lol"]
    await lol_pipeline.clear()

loop_run(clear_everything())