weaver.store.base

Module Contents

weaver.store.base.JobGroupCategory[source]
weaver.store.base.StoreServicesType[source]
weaver.store.base.StoreProcessesType[source]
weaver.store.base.StoreJobsType[source]
weaver.store.base.StoreBillsType[source]
weaver.store.base.StoreQuotesType[source]
weaver.store.base.StoreVaultType[source]
weaver.store.base.StoreTypeName[source]
class weaver.store.base.StoreInterface(settings: weaver.typedefs.SettingsType | None = None)[source]
type: StoreTypeName[source]
settings: weaver.typedefs.SettingsType[source]
class weaver.store.base.StoreServices(settings: weaver.typedefs.SettingsType | None = None)[source]
type[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: weaver.visibility.AnyVisibility | None = 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: weaver.typedefs.SettingsType | None = None)[source]
type[source]
abstract save_process(process: weaver.datatype.Process | pywps.Process, overwrite: bool = True) → weaver.datatype.Process[source]
abstract delete_process(process_id: weaver.typedefs.AnyProcessRef, visibility: weaver.visibility.AnyVisibility | None = None) → bool[source]
abstract list_processes(visibility: weaver.visibility.AnyVisibility | List[weaver.visibility.AnyVisibility] | None = None, page: int | None = None, limit: int | None = None, sort: weaver.sort.AnySortType | None = None, total: bool = False, revisions: bool = False, process: str | None = None) → List[weaver.datatype.Process] | Tuple[List[weaver.datatype.Process], int][source]
abstract fetch_by_id(process_id: weaver.typedefs.AnyProcessRef, visibility: weaver.visibility.AnyVisibility | None = None) → weaver.datatype.Process[source]
abstract find_versions(process_id: weaver.typedefs.AnyProcessRef, version_format: weaver.utils.VersionFormat = VersionFormat.OBJECT) → List[weaver.typedefs.AnyVersion][source]
abstract update_version(process_id: weaver.typedefs.AnyProcessRef, version: weaver.typedefs.AnyVersion) → weaver.datatype.Process[source]
abstract get_estimator(process_id: weaver.typedefs.AnyProcessRef) → weaver.typedefs.JSON[source]
abstract set_estimator(process_id: weaver.typedefs.AnyProcessRef, estimator: weaver.typedefs.JSON) → None[source]
abstract get_visibility(process_id: weaver.typedefs.AnyProcessRef) → weaver.visibility.AnyVisibility[source]
abstract set_visibility(process_id: weaver.typedefs.AnyProcessRef, visibility: weaver.visibility.AnyVisibility) → None[source]
abstract clear_processes() → bool[source]
class weaver.store.base.StoreJobs(settings: weaver.typedefs.SettingsType | None = None)[source]
type[source]
abstract save_job(task_id: str, process: weaver.typedefs.AnyProcessRef, service: weaver.typedefs.AnyServiceRef | None = None, inputs: weaver.typedefs.ExecutionInputs | None = None, outputs: weaver.typedefs.ExecutionOutputs | None = None, is_workflow: bool = False, is_local: bool = False, execute_async: bool = True, execute_response: weaver.execute.AnyExecuteResponse | None = None, custom_tags: List[str] | None = None, user_id: int | None = None, access: weaver.visibility.AnyVisibility | None = None, context: str | None = None, subscribers: weaver.typedefs.ExecutionSubscribers | None = None, accept_language: str | None = None, created: datetime.datetime | None = 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: str | None = None, service: str | None = None, job_type: str | None = None, tags: List[str] | None = None, access: str | None = None, status: weaver.status.AnyStatusSearch | List[weaver.status.AnyStatusSearch] | None = None, sort: weaver.sort.AnySortType | None = None, page: int | None = 0, limit: int | None = 10, min_duration: int | None = None, max_duration: int | None = None, datetime_interval: weaver.typedefs.DatetimeIntervalType | None = None, group_by: str | List[str] | None = None, request: pyramid.request.Request | None = None) → JobSearchResult[source]
abstract clear_jobs() → bool[source]
class weaver.store.base.StoreQuotes(settings: weaver.typedefs.SettingsType | None = None)[source]
type[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: str | None = None, page: int = 0, limit: int = 10, sort: weaver.sort.AnySortType | None = 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: weaver.typedefs.SettingsType | None = None)[source]
type[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: str | None = None, page: int = 0, limit: int = 10, sort: weaver.sort.AnySortType | None = None) → Tuple[List[weaver.datatype.Bill], int][source]
class weaver.store.base.StoreVault(settings: weaver.typedefs.SettingsType | None = None)[source]
type[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: weaver.datatype.VaultFile | weaver.typedefs.AnyUUID) → bool[source]