fiftyone.factory

• fiftyone.factory.repos
  • fiftyone.factory.repos.delegated_operation
    • DelegatedOperationRepo
      • DelegatedOperationRepo.queue_operation()
      • DelegatedOperationRepo.update_run_state()
      • DelegatedOperationRepo.update_progress()
      • DelegatedOperationRepo.get_queued_operations()
      • DelegatedOperationRepo.get_scheduled_operations()
      • DelegatedOperationRepo.get_running_operations()
      • DelegatedOperationRepo.list_operations()
      • DelegatedOperationRepo.delete_operation()
      • DelegatedOperationRepo.delete_for_dataset()
      • DelegatedOperationRepo.set_pinned()
      • DelegatedOperationRepo.set_label()
      • DelegatedOperationRepo.set_log_upload_error()
      • DelegatedOperationRepo.set_log_size()
      • DelegatedOperationRepo.get()
      • DelegatedOperationRepo.count()
      • DelegatedOperationRepo.ping()
    • MongoDelegatedOperationRepo
      • MongoDelegatedOperationRepo.COLLECTION_NAME
      • MongoDelegatedOperationRepo.required_props
      • MongoDelegatedOperationRepo.queue_operation()
      • MongoDelegatedOperationRepo.set_pinned()
      • MongoDelegatedOperationRepo.set_label()
      • MongoDelegatedOperationRepo.set_log_upload_error()
      • MongoDelegatedOperationRepo.set_log_size()
      • MongoDelegatedOperationRepo.update_run_state()
      • MongoDelegatedOperationRepo.update_progress()
      • MongoDelegatedOperationRepo.get_queued_operations()
      • MongoDelegatedOperationRepo.get_scheduled_operations()
      • MongoDelegatedOperationRepo.get_running_operations()
      • MongoDelegatedOperationRepo.list_operations()
      • MongoDelegatedOperationRepo.delete_operation()
      • MongoDelegatedOperationRepo.delete_for_dataset()
      • MongoDelegatedOperationRepo.get()
      • MongoDelegatedOperationRepo.count()
      • MongoDelegatedOperationRepo.ping()
  • fiftyone.factory.repos.delegated_operation_doc
    • DelegatedOperationDocument
      • DelegatedOperationDocument.num_distributed_tasks
      • DelegatedOperationDocument.from_pymongo()
      • DelegatedOperationDocument.to_pymongo()
  • fiftyone.factory.repos.execution_store
    • ExecutionStoreRepo
      • ExecutionStoreRepo.create_store()
      • ExecutionStoreRepo.clear_cache()
      • ExecutionStoreRepo.get_store()
      • ExecutionStoreRepo.has_store()
      • ExecutionStoreRepo.list_stores()
      • ExecutionStoreRepo.count_stores()
      • ExecutionStoreRepo.delete_store()
      • ExecutionStoreRepo.set_key()
      • ExecutionStoreRepo.set_cache_key()
      • ExecutionStoreRepo.has_key()
      • ExecutionStoreRepo.get_key()
      • ExecutionStoreRepo.update_ttl()
      • ExecutionStoreRepo.delete_key()
      • ExecutionStoreRepo.list_keys()
      • ExecutionStoreRepo.count_keys()
      • ExecutionStoreRepo.cleanup()
      • ExecutionStoreRepo.has_store_global()
      • ExecutionStoreRepo.list_stores_global()
      • ExecutionStoreRepo.count_stores_global()
      • ExecutionStoreRepo.delete_store_global()
    • MongoExecutionStoreRepo
      • MongoExecutionStoreRepo.COLLECTION_NAME
      • MongoExecutionStoreRepo.create_store()
      • MongoExecutionStoreRepo.clear_cache()
      • MongoExecutionStoreRepo.get_store()
      • MongoExecutionStoreRepo.has_store()
      • MongoExecutionStoreRepo.list_stores()
      • MongoExecutionStoreRepo.count_stores()
      • MongoExecutionStoreRepo.delete_store()
      • MongoExecutionStoreRepo.set_key()
      • MongoExecutionStoreRepo.set_cache_key()
      • MongoExecutionStoreRepo.has_key()
      • MongoExecutionStoreRepo.get_key()
      • MongoExecutionStoreRepo.update_ttl()
      • MongoExecutionStoreRepo.delete_key()
      • MongoExecutionStoreRepo.list_keys()
      • MongoExecutionStoreRepo.count_keys()
      • MongoExecutionStoreRepo.cleanup()
      • MongoExecutionStoreRepo.has_store_global()
      • MongoExecutionStoreRepo.list_stores_global()
      • MongoExecutionStoreRepo.count_stores_global()
      • MongoExecutionStoreRepo.delete_store_global()
    • InMemoryExecutionStoreRepo
      • InMemoryExecutionStoreRepo.create_store()
      • InMemoryExecutionStoreRepo.clear_cache()
      • InMemoryExecutionStoreRepo.get_store()
      • InMemoryExecutionStoreRepo.has_store()
      • InMemoryExecutionStoreRepo.list_stores()
      • InMemoryExecutionStoreRepo.count_stores()
      • InMemoryExecutionStoreRepo.delete_store()
      • InMemoryExecutionStoreRepo.set_key()
      • InMemoryExecutionStoreRepo.set_cache_key()
      • InMemoryExecutionStoreRepo.has_key()
      • InMemoryExecutionStoreRepo.get_key()
      • InMemoryExecutionStoreRepo.update_ttl()
      • InMemoryExecutionStoreRepo.update_policy()
      • InMemoryExecutionStoreRepo.delete_key()
      • InMemoryExecutionStoreRepo.list_keys()
      • InMemoryExecutionStoreRepo.count_keys()
      • InMemoryExecutionStoreRepo.cleanup()
      • InMemoryExecutionStoreRepo.has_store_global()
      • InMemoryExecutionStoreRepo.list_stores_global()
      • InMemoryExecutionStoreRepo.count_stores_global()
      • InMemoryExecutionStoreRepo.delete_store_global()
  • Module contents

• fiftyone.factory.repo_factory
  • RepositoryFactory
    • RepositoryFactory.repos
    • RepositoryFactory.delegated_operation_repo()
    • RepositoryFactory.execution_store_repo()

Module contents

FiftyOne repository factory.

Copyright 2017-2025, Voxel51, Inc.

voxel51.com

Classes:

SortByField()	Sort by enum for delegated operations.
SortDirection()	Sort direction enum for delegated operations.
DelegatedOperationPagingParams([sort_by, ...])	Paging parameters for delegated operations.

class fiftyone.factory.SortByField

Bases: object

Sort by enum for delegated operations.

Attributes:

UPDATED_AT
SCHEDULED_AT
QUEUED_AT
COMPLETED_AT
STARTED_AT
FAILED_AT
OPERATOR

UPDATED_AT = 'updated_at'

SCHEDULED_AT = 'scheduled_at'

QUEUED_AT = 'queued_at'

COMPLETED_AT = 'completed_at'

STARTED_AT = 'started_at'

FAILED_AT = 'failed_at'

OPERATOR = 'operator'

class fiftyone.factory.SortDirection

Bases: object

Sort direction enum for delegated operations.

Attributes:

ASCENDING
DESCENDING

ASCENDING = 1

DESCENDING = -1

class fiftyone.factory.DelegatedOperationPagingParams(sort_by: SortByField = 'queued_at', sort_direction: SortDirection = -1, skip: int = 0, limit: int = 10)

Bases: object

Paging parameters for delegated operations.