fiftyone.factory.repos.delegated_operation.MongoDelegatedOperationRepo

class documentation

class MongoDelegatedOperationRepo(DelegatedOperationRepo): (source)

Constructor: MongoDelegatedOperationRepo(collection)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method count Count all operations.
Method delete_for_dataset Delete an operation.
Method delete_operation Delete an operation.
Method get Get an operation by id.
Method get_queued_operations Get all queued operations.
Method get_running_operations Get all running operations.
Method get_scheduled_operations Get all scheduled operations.
Method list_operations List all operations.
Method queue_operation Queue an operation to be executed by a delegated operator.
Method set_label Sets the label for the delegated operation.
Method set_pinned Sets the pinned flag on / off.
Method update_progress Update the progress of an operation.
Method update_run_state Update the run state of an operation.
Constant COLLECTION_NAME Undocumented
Class Variable required_props Undocumented
Instance Variable is_remote Undocumented
Method _create_indexes Undocumented
Method _extract_search_query Undocumented
Method _get_collection Undocumented
Instance Variable _collection Undocumented
def __init__(self, collection: Collection = None): (source)

Undocumented

def count(self, filters: dict = None, search: dict = None) -> int: (source)
overrides fiftyone.factory.repos.delegated_operation.DelegatedOperationRepo.count

Count all operations.

def delete_for_dataset(self, dataset_id: ObjectId): (source)
overrides fiftyone.factory.repos.delegated_operation.DelegatedOperationRepo.delete_for_dataset

Delete an operation.

def delete_operation(self, _id: ObjectId) -> DelegatedOperationDocument: (source)
overrides fiftyone.factory.repos.delegated_operation.DelegatedOperationRepo.delete_operation

Delete an operation.

def get(self, _id: ObjectId) -> DelegatedOperationDocument: (source)
overrides fiftyone.factory.repos.delegated_operation.DelegatedOperationRepo.get

Get an operation by id.

def get_queued_operations(self, operator: str = None, dataset_name: ObjectId = None) -> list[DelegatedOperationDocument]: (source)
overrides fiftyone.factory.repos.delegated_operation.DelegatedOperationRepo.get_queued_operations

Get all queued operations.

def get_running_operations(self, operator: str = None, dataset_name: ObjectId = None) -> list[DelegatedOperationDocument]: (source)
overrides fiftyone.factory.repos.delegated_operation.DelegatedOperationRepo.get_running_operations

Get all running operations.

def get_scheduled_operations(self, operator: str = None, dataset_name: ObjectId = None) -> list[DelegatedOperationDocument]: (source)
overrides fiftyone.factory.repos.delegated_operation.DelegatedOperationRepo.get_scheduled_operations

Get all scheduled operations.

def list_operations(self, operator: str = None, dataset_name: str = None, dataset_id: ObjectId = None, run_state: ExecutionRunState = None, delegation_target: str = None, pinned: bool = None, paging: DelegatedOperationPagingParams = None, search: dict = None, **kwargs: Any) -> list[DelegatedOperationDocument]: (source)
overrides fiftyone.factory.repos.delegated_operation.DelegatedOperationRepo.list_operations

List all operations.

def queue_operation(self, **kwargs: Any) -> DelegatedOperationDocument: (source)
overrides fiftyone.factory.repos.delegated_operation.DelegatedOperationRepo.queue_operation

Queue an operation to be executed by a delegated operator.

def set_label(self, _id: ObjectId, label: str) -> DelegatedOperationDocument: (source)
overrides fiftyone.factory.repos.delegated_operation.DelegatedOperationRepo.set_label

Sets the label for the delegated operation.

def set_pinned(self, _id: ObjectId, pinned: bool = True) -> DelegatedOperationDocument: (source)
overrides fiftyone.factory.repos.delegated_operation.DelegatedOperationRepo.set_pinned

Sets the pinned flag on / off.

def update_progress(self, _id: ObjectId, progress: ExecutionProgress) -> DelegatedOperationDocument: (source)
overrides fiftyone.factory.repos.delegated_operation.DelegatedOperationRepo.update_progress

Update the progress of an operation.

def update_run_state(self, _id: ObjectId, run_state: ExecutionRunState, result: ExecutionResult = None, run_link: str = None, progress: ExecutionProgress = None, required_state: ExecutionRunState = None) -> DelegatedOperationDocument: (source)
overrides fiftyone.factory.repos.delegated_operation.DelegatedOperationRepo.update_run_state

Update the run state of an operation.

COLLECTION_NAME: str = (source)

Undocumented

Value
'delegated_ops'
required_props: list[str] = (source)

Undocumented

is_remote = (source)

Undocumented

def _create_indexes(self): (source)

Undocumented

def _extract_search_query(self, search): (source)

Undocumented

def _get_collection(self) -> Collection: (source)

Undocumented

_collection = (source)

Undocumented