weaver.store.base

Module Contents

weaver.store.base.JobGroupCategory[source]
class weaver.store.base.StoreInterface[source]
type[source]
class weaver.store.base.StoreServices[source]
type = services[source]
abstract save_service(self: weaver.datatype.Service, service: bool, overwrite=True)weaver.datatype.Service[source]
abstract delete_service(self: str, name)bool[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]
abstract clear_services(self)bool[source]
class weaver.store.base.StoreProcesses[source]
type = processes[source]
abstract save_process(self: Union[weaver.datatype.Process, pywps.Process], process: bool, overwrite=True)weaver.datatype.Process[source]
abstract delete_process(self: str, process_id: Optional[str], visibility=None)bool[source]
abstract list_processes(self: Optional[str], visibility=None)List[weaver.datatype.Process][source]
abstract fetch_by_id(self: str, process_id: Optional[str], visibility=None)weaver.datatype.Process[source]
abstract get_visibility(self: str, process_id)str[source]
abstract set_visibility(self: str, process_id: str, visibility)None[source]
abstract clear_processes(self)bool[source]
class weaver.store.base.StoreJobs[source]
type = jobs[source]
abstract save_job(self: Ellipsis, task_id: str, process: str, service: Optional[str] = None, inputs: Optional[List[Any]] = None, is_workflow: bool = False, is_local: bool = False, execute_async: bool = True, 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 delete_job(self: str, job_id)bool[source]
abstract fetch_by_id(self: str, 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: int = 0, limit: 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]
abstract clear_jobs(self)bool[source]
class weaver.store.base.StoreQuotes[source]
type = quotes[source]
abstract save_quote(self: weaver.datatype.Quote, quote)weaver.datatype.Quote[source]
abstract fetch_by_id(self: str, 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]
class weaver.store.base.StoreBills[source]
type = bills[source]
abstract save_bill(self: weaver.datatype.Bill, bill)weaver.datatype.Bill[source]
abstract fetch_by_id(self: str, bill_id)weaver.datatype.Bill[source]
abstract list_bills(self: Ellipsis)List[weaver.datatype.Bill][source]
abstract find_bills(self: Optional[str], quote_id: int = None, page: int = 0, limit: Optional[str] = 10, sort=None)Tuple[List[weaver.datatype.Bill], int][source]