weaver.store.base

Module Contents

weaver.store.base.JobGroupCategory

weaver.store.base.StoreServicesType

weaver.store.base.StoreProcessesType

weaver.store.base.StoreJobsType

weaver.store.base.StoreBillsType

weaver.store.base.StoreQuotesType

weaver.store.base.StoreVaultType

weaver.store.base.StoreTypeName

class weaver.store.base.StoreInterface(settings: weaver.typedefs.SettingsType | None = None)

type: StoreTypeName = None

settings: weaver.typedefs.SettingsType = None

class weaver.store.base.StoreServices(settings: weaver.typedefs.SettingsType | None = None)

type

abstract save_service(service: weaver.datatype.Service, overwrite: bool = True) → weaver.datatype.Service

abstract delete_service(name: str) → bool

abstract list_services() → List[weaver.datatype.Service]

abstract fetch_by_name(name: str, visibility: weaver.visibility.AnyVisibility | None = None) → weaver.datatype.Service

abstract fetch_by_url(url: str) → weaver.datatype.Service

abstract clear_services() → bool

class weaver.store.base.StoreProcesses(settings: weaver.typedefs.SettingsType | None = None)

type

abstract save_process(process: weaver.datatype.Process | pywps.Process, overwrite: bool = True) → weaver.datatype.Process

abstract delete_process(process_id: weaver.typedefs.AnyProcessRef, visibility: weaver.visibility.AnyVisibility | None = None) → bool

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]

abstract fetch_by_id(process_id: weaver.typedefs.AnyProcessRef, visibility: weaver.visibility.AnyVisibility | None = None) → weaver.datatype.Process

abstract find_versions(process_id: weaver.typedefs.AnyProcessRef, version_format: weaver.utils.VersionFormat = VersionFormat.OBJECT) → List[weaver.typedefs.AnyVersion]

abstract update_version(process_id: weaver.typedefs.AnyProcessRef, version: weaver.typedefs.AnyVersion) → weaver.datatype.Process

abstract get_estimator(process_id: weaver.typedefs.AnyProcessRef) → weaver.typedefs.JSON

abstract set_estimator(process_id: weaver.typedefs.AnyProcessRef, estimator: weaver.typedefs.JSON) → None

abstract get_visibility(process_id: weaver.typedefs.AnyProcessRef) → weaver.visibility.AnyVisibility

abstract set_visibility(process_id: weaver.typedefs.AnyProcessRef, visibility: weaver.visibility.AnyVisibility) → None

abstract clear_processes() → bool

class weaver.store.base.StoreJobs(settings: weaver.typedefs.SettingsType | None = None)

type

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

abstract batch_update_jobs(job_filter: Dict[str, Any], job_update: Dict[str, Any]) → int

abstract update_job(job: weaver.datatype.Job) → weaver.datatype.Job

abstract delete_job(job_id: weaver.typedefs.AnyUUID) → bool

abstract fetch_by_id(job_id: weaver.typedefs.AnyUUID) → weaver.datatype.Job

abstract list_jobs() → List[weaver.datatype.Job]

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

abstract clear_jobs() → bool

class weaver.store.base.StoreQuotes(settings: weaver.typedefs.SettingsType | None = None)

type

abstract save_quote(quote: weaver.datatype.Quote) → weaver.datatype.Quote

abstract fetch_by_id(quote_id: weaver.typedefs.AnyUUID) → weaver.datatype.Quote

abstract list_quotes() → List[weaver.datatype.Quote]

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]

abstract update_quote(quote: weaver.datatype.Quote) → weaver.datatype.Quote

class weaver.store.base.StoreBills(settings: weaver.typedefs.SettingsType | None = None)

type

abstract save_bill(bill: weaver.datatype.Bill) → weaver.datatype.Bill

abstract fetch_by_id(bill_id: weaver.typedefs.AnyUUID) → weaver.datatype.Bill

abstract list_bills() → List[weaver.datatype.Bill]

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]

class weaver.store.base.StoreVault(settings: weaver.typedefs.SettingsType | None = None)

type

abstract get_file(file_id: weaver.typedefs.AnyUUID, nothrow: bool = False) → weaver.datatype.VaultFile

abstract save_file(file: weaver.datatype.VaultFile) → None

abstract delete_file(file: weaver.datatype.VaultFile | weaver.typedefs.AnyUUID) → bool