Tasks

General aggregation tasks are created here.

fma_core.workflows.tasks.agg_service(model_id: int) → Optional[int]

Runs aggregation for FMA.

Parameters:

model_id (int) – The id of the Federated Model Experiment

Raises:

• ValueError – Aggregator settings are not specified in settings

• ValueError – Aggregator type not specified in settings

Returns:

ID of newly created ModelAggregate

Return type:

int

fma_core.workflows.tasks.post_agg_service_hook(task: Any)

Runs postprocessing after aggregation is complete.

Parameters:

task (Any) – Object containing info on the previously ran aggregation task

Raises:

• ValueError – Error: aggregator settings are not specified in settings

• ValueError – Error: aggregator type not specified in settings

fma_core.workflows.tasks.update_metadata_db() → None

Updates the architecture of the metadata database.

Raises:

• ValueError – aggregator settings are not specified in settings

• ValueError – aggregator type not specified in settings