weaver.store.base ================= .. py:module:: weaver.store.base Module Contents --------------- .. py:data:: JobGroupCategory .. py:data:: StoreServicesType .. py:data:: StoreProcessesType .. py:data:: StoreJobsType .. py:data:: StoreBillsType .. py:data:: StoreQuotesType .. py:data:: StoreVaultType .. py:data:: StoreTypeName .. py:class:: StoreInterface(settings: Optional[weaver.typedefs.SettingsType] = None) .. py:attribute:: type :type: StoreTypeName :value: None .. py:attribute:: settings :type: weaver.typedefs.SettingsType :value: None .. py:class:: StoreServices(settings: Optional[weaver.typedefs.SettingsType] = None) .. py:attribute:: type .. py:method:: save_service(service: weaver.datatype.Service, overwrite: bool = True) -> weaver.datatype.Service :abstractmethod: .. py:method:: delete_service(name: str) -> bool :abstractmethod: .. py:method:: list_services() -> List[weaver.datatype.Service] :abstractmethod: .. py:method:: fetch_by_name(name: str, visibility: Optional[weaver.visibility.AnyVisibility] = None) -> weaver.datatype.Service :abstractmethod: .. py:method:: fetch_by_url(url: str) -> weaver.datatype.Service :abstractmethod: .. py:method:: clear_services() -> bool :abstractmethod: .. py:class:: StoreProcesses(settings: Optional[weaver.typedefs.SettingsType] = None) .. py:attribute:: type .. py:method:: save_process(process: Union[weaver.datatype.Process, pywps.Process], overwrite: bool = True) -> weaver.datatype.Process :abstractmethod: .. py:method:: delete_process(process_id: weaver.typedefs.AnyProcessRef, visibility: Optional[weaver.visibility.AnyVisibility] = None) -> bool :abstractmethod: .. py:method:: list_processes(visibility: Optional[weaver.visibility.AnyVisibility, List[weaver.visibility.AnyVisibility]] = None, page: Optional[int] = None, limit: Optional[int] = None, sort: Optional[weaver.sort.AnySortType] = None, total: bool = False, revisions: bool = False, process: Optional[str] = None) -> Union[List[weaver.datatype.Process], Tuple[List[weaver.datatype.Process], int]] :abstractmethod: .. py:method:: fetch_by_id(process_id: weaver.typedefs.AnyProcessRef, visibility: Optional[weaver.visibility.AnyVisibility] = None) -> weaver.datatype.Process :abstractmethod: .. py:method:: find_versions(process_id: weaver.typedefs.AnyProcessRef, version_format: weaver.utils.VersionFormat = VersionFormat.OBJECT) -> List[weaver.typedefs.AnyVersion] :abstractmethod: .. py:method:: update_version(process_id: weaver.typedefs.AnyProcessRef, version: weaver.typedefs.AnyVersion) -> weaver.datatype.Process :abstractmethod: .. py:method:: get_estimator(process_id: weaver.typedefs.AnyProcessRef) -> weaver.typedefs.JSON :abstractmethod: .. py:method:: set_estimator(process_id: weaver.typedefs.AnyProcessRef, estimator: weaver.typedefs.JSON) -> None :abstractmethod: .. py:method:: get_visibility(process_id: weaver.typedefs.AnyProcessRef) -> weaver.visibility.AnyVisibility :abstractmethod: .. py:method:: set_visibility(process_id: weaver.typedefs.AnyProcessRef, visibility: weaver.visibility.AnyVisibility) -> None :abstractmethod: .. py:method:: clear_processes() -> bool :abstractmethod: .. py:class:: StoreJobs(settings: Optional[weaver.typedefs.SettingsType] = None) .. py:attribute:: type .. py:method:: save_job(task_id: str, process: weaver.typedefs.AnyProcessRef, service: Optional[weaver.typedefs.AnyServiceRef] = None, inputs: Optional[weaver.typedefs.ExecutionInputs] = None, outputs: Optional[weaver.typedefs.ExecutionOutputs] = None, is_workflow: bool = False, is_local: bool = False, execute_mode: Optional[weaver.execute.AnyExecuteMode] = None, execute_wait: Optional[int] = None, execute_response: Optional[weaver.execute.AnyExecuteResponse] = None, execute_return: Optional[weaver.execute.AnyExecuteReturnPreference] = None, custom_tags: Optional[List[str]] = None, user_id: Optional[int] = None, access: Optional[weaver.visibility.AnyVisibility] = None, context: Optional[str] = None, subscribers: Optional[weaver.typedefs.ExecutionSubscribers] = None, accept_type: Optional[str] = None, accept_language: Optional[str] = None, created: Optional[datetime.datetime] = None, status: Optional[weaver.status.AnyStatusType] = None) -> weaver.datatype.Job :abstractmethod: .. py:method:: batch_update_jobs(job_filter: Dict[str, Any], job_update: Dict[str, Any]) -> int :abstractmethod: .. py:method:: update_job(job: weaver.datatype.Job) -> weaver.datatype.Job :abstractmethod: .. py:method:: delete_job(job_id: weaver.typedefs.AnyUUID) -> bool :abstractmethod: .. py:method:: fetch_by_id(job_id: weaver.typedefs.AnyUUID) -> weaver.datatype.Job :abstractmethod: .. py:method:: list_jobs() -> List[weaver.datatype.Job] :abstractmethod: .. py:method:: find_jobs(process: Optional[str] = None, service: Optional[str] = None, job_type: Optional[str] = None, tags: Optional[List[str]] = None, access: Optional[str] = None, status: Optional[weaver.status.AnyStatusSearch, List[weaver.status.AnyStatusSearch]] = None, sort: Optional[weaver.sort.AnySortType] = 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 :abstractmethod: .. py:method:: clear_jobs() -> bool :abstractmethod: .. py:class:: StoreQuotes(settings: Optional[weaver.typedefs.SettingsType] = None) .. py:attribute:: type .. py:method:: save_quote(quote: weaver.datatype.Quote) -> weaver.datatype.Quote :abstractmethod: .. py:method:: fetch_by_id(quote_id: weaver.typedefs.AnyUUID) -> weaver.datatype.Quote :abstractmethod: .. py:method:: list_quotes() -> List[weaver.datatype.Quote] :abstractmethod: .. py:method:: find_quotes(process_id: Optional[str] = None, page: int = 0, limit: int = 10, sort: Optional[weaver.sort.AnySortType] = None) -> Tuple[List[weaver.datatype.Quote], int] :abstractmethod: .. py:method:: update_quote(quote: weaver.datatype.Quote) -> weaver.datatype.Quote :abstractmethod: .. py:class:: StoreBills(settings: Optional[weaver.typedefs.SettingsType] = None) .. py:attribute:: type .. py:method:: save_bill(bill: weaver.datatype.Bill) -> weaver.datatype.Bill :abstractmethod: .. py:method:: fetch_by_id(bill_id: weaver.typedefs.AnyUUID) -> weaver.datatype.Bill :abstractmethod: .. py:method:: list_bills() -> List[weaver.datatype.Bill] :abstractmethod: .. py:method:: find_bills(quote_id: Optional[str] = None, page: int = 0, limit: int = 10, sort: Optional[weaver.sort.AnySortType] = None) -> Tuple[List[weaver.datatype.Bill], int] :abstractmethod: .. py:class:: StoreVault(settings: Optional[weaver.typedefs.SettingsType] = None) .. py:attribute:: type .. py:method:: get_file(file_id: weaver.typedefs.AnyUUID, nothrow: bool = False) -> weaver.datatype.VaultFile :abstractmethod: .. py:method:: save_file(file: weaver.datatype.VaultFile) -> None :abstractmethod: .. py:method:: delete_file(file: Union[weaver.datatype.VaultFile, weaver.typedefs.AnyUUID]) -> bool :abstractmethod: