services¶

common¶

class GenericService(repository: SQLAlchemyRepository)¶

Bases: Generic[T_dom]

async create(obj: T_dom)¶

async delete(id: UUID)¶

async get(name: str | None = None, id: UUID | None = None) → T_dom | None¶

async list()¶

async update(id: UUID, obj: T_dom)¶

tempfile_delete_on_error(mode='w+b', suffix=None, prefix=None, dir=None)¶

dataset¶

class DatasetService(repository: SQLAlchemyRepository, serializer: ExternalSerializationStrategy, tmpfile_dir: Path)¶

Bases: object

async create(dataset: Dataset)¶

async get(name: str | None = None, id: UUID | None = None) → Dataset | None¶

async get_binary_data(dataset_id: UUID)¶

async get_dataset_as_file(dataset_id: UUID, filetype: FileType = FileType.JSON)¶

async get_entity_data(dataset_id: UUID)¶

async get_unstructured_data(dataset_id: UUID)¶

async list()¶

async stream_binary_data(dataset_id: UUID)¶

async update(dataset_id: UUID, dataset: Dataset)¶

async update_from_file(dataset_id: UUID, path: Path, mimetype: str | None = None)¶

general¶

class AttributeTypeService(repository: SQLAlchemyRepository)¶

Bases: GenericService[AttributeType]

async as_schema()¶

class DatasetTypeService(repository: SQLAlchemyRepository)¶: Bases: GenericService[DatasetType]

class EntityTypeService(repository: SQLAlchemyRepository)¶: Bases: GenericService[EntityType]

class ModelTypeService(repository: SQLAlchemyRepository)¶: Bases: GenericService[ModelType]

class WorkspaceService(repository: SQLAlchemyRepository)¶

Bases: GenericService[Workspace]

async ensure_valid_workspace(name_or_id: str) → Workspace¶

async get_with_counts(name: str | None = None, id: UUID | None = None)¶

scenario¶

class ScenarioService(repository: SQLAlchemyRepository, single_scenario_mode: bool)¶

Bases: object

async create(scenario: Scenario, validator: ModelConfigValidator)¶

async delete()¶

async get(name: str | None = None, id: UUID | None = None) → Scenario | None¶

async list()¶

async update(scenario: Scenario, validator)¶

update¶

class UpdateService(repository: SQLAlchemyRepository, serializer: ExternalSerializationStrategy, tmpfile_dir: Path)¶

Bases: object

async delete_all()¶

async get_update_as_file(update_id: UUID, filetype: FileType = FileType.JSON) → Path¶

async list()¶

async store_update_from_file(path: Path, filetype: FileType | None = None) → UUID¶