weaver.store.base
Module Contents
- class weaver.store.base.StoreServices(settings=None)[source]
-
- abstract save_service(self: weaver.datatype.Service, service: bool, overwrite=True) weaver.datatype.Service [source]
- abstract list_services(self) List[weaver.datatype.Service] [source]
- abstract fetch_by_name(self: str, name: Optional[str], visibility=None) weaver.datatype.Service [source]
- abstract fetch_by_url(self: str, url) weaver.datatype.Service [source]
- class weaver.store.base.StoreProcesses(settings=None)[source]
-
- abstract save_process(self: Union[weaver.datatype.Process, pywps.Process], process: bool, overwrite=True) weaver.datatype.Process [source]
- abstract list_processes(self: Ellipsis, visibility: Optional[str] = None, page: Optional[int] = None, limit: Optional[int] = None, sort: Optional[str] = None, total: bool = False) Union[List[weaver.datatype.Process], Tuple[List[weaver.datatype.Process], int]] [source]
- abstract fetch_by_id(self: str, process_id: Optional[str], visibility=None) weaver.datatype.Process [source]
- class weaver.store.base.StoreJobs(settings=None)[source]
-
- abstract save_job(self: Ellipsis, task_id: str, process: str, service: Optional[str] = None, inputs: Optional[weaver.typedefs.ExecutionInputs] = None, outputs: Optional[weaver.typedefs.ExecutionOutputs] = None, is_workflow: bool = False, is_local: bool = False, execute_async: bool = True, execute_response: Optional[weaver.execute.AnyExecuteResponse] = None, custom_tags: Optional[List[str]] = None, user_id: Optional[int] = None, access: Optional[str] = None, context: Optional[str] = None, notification_email: Optional[str] = None, accept_language: Optional[str] = None, created: Optional[datetime.datetime] = None) weaver.datatype.Job [source]
- abstract update_job(self: weaver.datatype.Job, job) weaver.datatype.Job [source]
- abstract fetch_by_id(self: weaver.typedefs.AnyUUID, job_id) weaver.datatype.Job [source]
- abstract list_jobs(self) List[weaver.datatype.Job] [source]
- abstract find_jobs(self: Ellipsis, process: Optional[str] = None, service: Optional[str] = None, job_type: Optional[str] = None, tags: Optional[List[str]] = None, access: Optional[str] = None, notification_email: Optional[str] = None, status: Optional[str] = None, sort: Optional[str] = None, page: Optional[int] = 0, limit: Optional[int] = 10, min_duration: Optional[int] = None, max_duration: Optional[int] = None, datetime_interval: Optional[weaver.typedefs.DatetimeIntervalType] = None, group_by: Optional[Union[str, List[str]]] = None, request: Optional[pyramid.request.Request] = None) JobSearchResult [source]
- class weaver.store.base.StoreQuotes(settings=None)[source]
-
- abstract save_quote(self: weaver.datatype.Quote, quote) weaver.datatype.Quote [source]
- abstract fetch_by_id(self: weaver.typedefs.AnyUUID, quote_id) weaver.datatype.Quote [source]
- abstract list_quotes(self: Ellipsis) List[weaver.datatype.Quote] [source]
- abstract find_quotes(self: Optional[str], process_id: int = None, page: int = 0, limit: Optional[str] = 10, sort=None) Tuple[List[weaver.datatype.Quote], int] [source]
- abstract update_quote(self: weaver.datatype.Quote, quote) weaver.datatype.Quote [source]
- class weaver.store.base.StoreBills(settings=None)[source]
-
- abstract save_bill(self: weaver.datatype.Bill, bill) weaver.datatype.Bill [source]
- abstract fetch_by_id(self: weaver.typedefs.AnyUUID, bill_id) weaver.datatype.Bill [source]
- abstract list_bills(self: Ellipsis) List[weaver.datatype.Bill] [source]
- class weaver.store.base.StoreVault(settings=None)[source]
-
- abstract get_file(self: weaver.typedefs.AnyUUID, file_id: bool, nothrow=False) weaver.datatype.VaultFile [source]
- abstract save_file(self: weaver.datatype.VaultFile, file) None [source]
- abstract delete_file(self: Union[weaver.datatype.VaultFile, weaver.typedefs.AnyUUID], file) bool [source]