Links

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())
Last modified 1yr ago