AggregatorConfig#

class lsst.pipe.base.quantum_graph.aggregator.AggregatorConfig(*, output_path: str | None = None, worker_log_dir: str | None = None, worker_log_level: str = 'VERBOSE', worker_profile_dir: str | None = None, n_processes: int = 1, incomplete: bool = False, defensive_ingest: bool = False, ingest_batch_size: int = 10000, register_dataset_types: bool = True, update_output_chain: bool = True, dry_run: bool = False, interactive_status: bool = False, log_status_interval: float | None = None, worker_sleep: float = 0.01, zstd_level: int = 10, zstd_dict_size: int = 32768, zstd_dict_n_inputs: int = 512, mock_storage_classes: bool = False, promise_ingest_graph: bool = False, worker_check_timeout: float = 5.0)#

Bases: BaseModel

Configuration for the provenance aggregator.

Attributes Summary

is_writing_provenance

Whether the aggregator is configured to write the provenance quantum graph.

model_config

Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

Methods Summary

copy(*args, **kwargs)

See pydantic.BaseModel.copy.

model_construct(*args, **kwargs)

See pydantic.BaseModel.model_construct.

model_copy(*args, **kwargs)

See pydantic.BaseModel.model_copy.

model_dump(*args, **kwargs)

See pydantic.BaseModel.model_dump.

model_dump_json(*args, **kwargs)

See pydantic.BaseModel.model_dump_json.

model_json_schema(*args, **kwargs)

See pydantic.BaseModel.model_json_schema.

model_validate(*args, **kwargs)

See pydantic.BaseModel.model_validate.

model_validate_json(*args, **kwargs)

See pydantic.BaseModel.model_validate_json.

model_validate_strings(*args, **kwargs)

See pydantic.BaseModel.model_validate_strings.

Attributes Documentation

is_writing_provenance#

Whether the aggregator is configured to write the provenance quantum graph.

model_config: ClassVar[ConfigDict] = {}#

Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

Methods Documentation

copy(*args: Any, **kwargs: Any) → Any#

See pydantic.BaseModel.copy.

classmethod model_construct(*args: Any, **kwargs: Any) → Any#

See pydantic.BaseModel.model_construct.

model_copy(*args: Any, **kwargs: Any) → Any#

See pydantic.BaseModel.model_copy.

model_dump(*args: Any, **kwargs: Any) → Any#

See pydantic.BaseModel.model_dump.

model_dump_json(*args: Any, **kwargs: Any) → Any#

See pydantic.BaseModel.model_dump_json.

classmethod model_json_schema(*args: Any, **kwargs: Any) → Any#

See pydantic.BaseModel.model_json_schema.

classmethod model_validate(*args: Any, **kwargs: Any) → Any#

See pydantic.BaseModel.model_validate.

classmethod model_validate_json(*args: Any, **kwargs: Any) → Any#

See pydantic.BaseModel.model_validate_json.

classmethod model_validate_strings(*args: Any, **kwargs: Any) → Any#

See pydantic.BaseModel.model_validate_strings.