weaver.store.base

Module Contents

weaver.store.base.JobGroupCategory[source]
class weaver.store.base.StoreInterface(settings: Optional[weaver.typedefs.SettingsType] = None)[source]
type :str[source]
settings :weaver.typedefs.SettingsType[source]
class weaver.store.base.StoreServices(settings: Optional[weaver.typedefs.SettingsType] = None)[source]
type = services[source]
abstract save_service(service: weaver.datatype.Service, overwrite: bool = True) weaver.datatype.Service[source]
abstract delete_service(name: str) bool[source]
abstract list_services() List[weaver.datatype.Service][source]
abstract fetch_by_name(name: str, visibility: Optional[weaver.visibility.AnyVisibility] = None) weaver.datatype.Service[source]
abstract fetch_by_url(url: str) weaver.datatype.Service[source]
abstract clear_services() bool[source]
class weaver.store.base.StoreProcesses(settings: Optional[weaver.typedefs.SettingsType] = None)[source]
type = processes[source]
abstract save_process(process: Union[weaver.datatype.Process, pywps.Process], overwrite: bool = True) weaver.datatype.Process[source]
abstract delete_process(process_id: str, visibility: Optional[weaver.visibility.AnyVisibility] = None) bool[source]
abstract list_processes(visibility: Ellipsis = None, page: Optional[int] = None, limit: Optional[int] = None, sort: Optional[str] = None, total: bool = False, revisions: bool = False, process: Optional[str] = None) Union[List[weaver.datatype.Process], Tuple[List[weaver.datatype.Process], int]][source]
abstract fetch_by_id(process_id: str, visibility: Optional[weaver.visibility.AnyVisibility] = None) weaver.datatype.Process[source]
abstract find_versions(process_id: str, version_format: weaver.utils.VersionFormat = VersionFormat.OBJECT) List[weaver.typedefs.AnyVersion][source]
abstract update_version(process_id: str, version: weaver.typedefs.AnyVersion) weaver.datatype.Process[source]
abstract get_visibility(process_id: str) weaver.visibility.AnyVisibility[source]
abstract set_visibility(process_id: str, visibility: weaver.visibility.AnyVisibility) None[source]
abstract clear_processes() bool[source]
class weaver.store.base.StoreJobs(settings: Optional[weaver.typedefs.SettingsType] = None)[source]
type = jobs[source]
abstract save_job(task_id: Ellipsis, 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[weaver.visibility.AnyVisibility] = 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 batch_update_jobs(job_filter: Dict[str, Any], job_update: Dict[str, Any]) int[source]
abstract update_job(job: weaver.datatype.Job) weaver.datatype.Job[source]
abstract delete_job(job_id: weaver.typedefs.AnyUUID) bool[source]
abstract fetch_by_id(job_id: weaver.typedefs.AnyUUID) weaver.datatype.Job[source]
abstract list_jobs() List[weaver.datatype.Job][source]
abstract find_jobs(process: Ellipsis = 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[weaver.status.AnyStatusSearch, List[weaver.status.AnyStatusSearch]] = 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]
abstract clear_jobs() bool[source]
class weaver.store.base.StoreQuotes(settings: Optional[weaver.typedefs.SettingsType] = None)[source]
type = quotes[source]
abstract save_quote(quote: weaver.datatype.Quote) weaver.datatype.Quote[source]
abstract fetch_by_id(quote_id: weaver.typedefs.AnyUUID) weaver.datatype.Quote[source]
abstract list_quotes() List[weaver.datatype.Quote][source]
abstract find_quotes(process_id: Optional[str] = None, page: int = 0, limit: int = 10, sort: Optional[str] = None) Tuple[List[weaver.datatype.Quote], int][source]
abstract update_quote(quote: weaver.datatype.Quote) weaver.datatype.Quote[source]
class weaver.store.base.StoreBills(settings: Optional[weaver.typedefs.SettingsType] = None)[source]
type = bills[source]
abstract save_bill(bill: weaver.datatype.Bill) weaver.datatype.Bill[source]
abstract fetch_by_id(bill_id: weaver.typedefs.AnyUUID) weaver.datatype.Bill[source]
abstract list_bills() List[weaver.datatype.Bill][source]
abstract find_bills(quote_id: Optional[str] = None, page: int = 0, limit: int = 10, sort: Optional[str] = None) Tuple[List[weaver.datatype.Bill], int][source]
class weaver.store.base.StoreVault(settings: Optional[weaver.typedefs.SettingsType] = None)[source]
type = vault[source]
abstract get_file(file_id: weaver.typedefs.AnyUUID, nothrow: bool = False) weaver.datatype.VaultFile[source]
abstract save_file(file: weaver.datatype.VaultFile) None[source]
abstract delete_file(file: Union[weaver.datatype.VaultFile, weaver.typedefs.AnyUUID]) bool[source]