fiftyone.factory.repos.delegated_operation.DelegatedOperationRepo

class documentation

class DelegatedOperationRepo(object): (source)

Known subclasses: fiftyone.factory.repos.delegated_operation.MongoDelegatedOperationRepo

View In Hierarchy

Base Class for a delegated operation repository.

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.
def count(self, filters: dict = None, search: dict = None) -> int: (source)
overridden in fiftyone.factory.repos.delegated_operation.MongoDelegatedOperationRepo

Count all operations.

def delete_for_dataset(self, dataset_id: ObjectId): (source)
overridden in fiftyone.factory.repos.delegated_operation.MongoDelegatedOperationRepo

Delete an operation.

def delete_operation(self, _id: ObjectId) -> DelegatedOperationDocument: (source)
overridden in fiftyone.factory.repos.delegated_operation.MongoDelegatedOperationRepo

Delete an operation.

def get(self, _id: ObjectId) -> DelegatedOperationDocument: (source)
overridden in fiftyone.factory.repos.delegated_operation.MongoDelegatedOperationRepo

Get an operation by id.

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

Get all queued operations.

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

Get all running operations.

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

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)
overridden in fiftyone.factory.repos.delegated_operation.MongoDelegatedOperationRepo

List all operations.

def queue_operation(self, **kwargs: Any) -> DelegatedOperationDocument: (source)
overridden in fiftyone.factory.repos.delegated_operation.MongoDelegatedOperationRepo

Queue an operation to be executed by a delegated operator.

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

Sets the label for the delegated operation.

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

Sets the pinned flag on / off.

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

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)
overridden in fiftyone.factory.repos.delegated_operation.MongoDelegatedOperationRepo

Update the run state of an operation.