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"]
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 overstores
.__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 bytoken()
on Pyot Core objects.
- async
set
->None
token
:PipelineToken
Token identifying the data, created bytoken()
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 bytoken()
on Pyot Core objects.body
->Any
Body of the request.
- async
put
->Any
token
:PipelineToken
Token identifying the data, created bytoken()
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 bytoken()
on Pyot Core objects.
- async
contains
->bool
token
:PipelineToken
Token identifying the data, created bytoken()
on Pyot Core objects.
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