dae.gpf_instance.adjustments package

Submodules

dae.gpf_instance.adjustments.adjust_command module

class dae.gpf_instance.adjustments.adjust_command.AdjustmentsCommand(instance_dir: str)[source]

Bases: ABC

Abstract class for adjusting an GPF instance config.

close() → None[source]

Save adjusted config.

abstract execute() → None[source]

Execute adjustment command.

dae.gpf_instance.adjustments.adjust_duckdb_storage module

class dae.gpf_instance.adjustments.adjust_duckdb_storage.AdjustDuckDbStorageCommand(instance_dir: str, storage_id: str, **adjustments: str | bool)[source]

Bases: AdjustmentsCommand

Adjusts impala storage.

static add_arguments(parser: ArgumentParser) → None[source]

Add arguments to parser.

execute() → None[source]

Execute adjustment command.

dae.gpf_instance.adjustments.adjust_impala_storage module

class dae.gpf_instance.adjustments.adjust_impala_storage.AdjustImpalaStorageCommand(instance_dir: str, storage_id: str, *, read_only: bool, hdfs_host: str | None = None, hdfs_base_dir: str | None = None, impala_hosts: list[str] | None = None, impala_db: str | None = None, **_kwargs: Any | bool)[source]

Bases: AdjustmentsCommand

Adjusts impala storage.

static add_arguments(parser: ArgumentParser) → None[source]

Add arguments to parser.

execute() → None[source]

Execute adjustment command.

dae.gpf_instance.adjustments.gpf_instance_adjustments module

class dae.gpf_instance.adjustments.gpf_instance_adjustments.DefaultGenotypeStorage(instance_dir: str, storage_id: str)[source]

Bases: StudyConfigsAdjustmentCommand

Adjust default genotype storage.

adjust_study(_study_id: str, study_config: dict[str, Any]) → dict[str, Any][source]
execute() → None[source]

Execute adjustment command.

class dae.gpf_instance.adjustments.gpf_instance_adjustments.EnableDisableStudies(instance_dir: str, study_ids: Iterable[str], *, enabled: bool = False)[source]

Bases: StudyConfigsAdjustmentCommand

Enable or disable collection of studies.

adjust_dataset(dataset_id: str, dataset_config: dict[str, Any]) → dict[str, Any][source]
adjust_study(study_id: str, study_config: dict[str, Any]) → dict[str, Any][source]
execute() → None[source]

Execute adjustment command.

class dae.gpf_instance.adjustments.gpf_instance_adjustments.InstanceIdCommand(instance_dir: str, instance_id: str)[source]

Bases: AdjustmentsCommand

Adjusts GPF instance ID.

execute() → None[source]

Execute adjustment command.

class dae.gpf_instance.adjustments.gpf_instance_adjustments.StudyConfigsAdjustmentCommand(instance_dir: str)[source]

Bases: AdjustmentsCommand

Command to adjust study configs.

adjust_dataset(_dataset_id: str, dataset_config: dict[str, Any]) → dict[str, Any][source]
adjust_study(_study_id: str, study_config: dict[str, Any]) → dict[str, Any][source]
dae.gpf_instance.adjustments.gpf_instance_adjustments.cli(argv: list[str] | None = None) → None[source]

Handle cli invocation.

Module contents