Workflows

Modules

• Aggregator Connectors Factory
  • BaseAggConnector
    • BaseAggConnector.create()
    • BaseAggConnector.pull_federated_model_w_id()
    • BaseAggConnector.pull_latest_model_aggregate()
    • BaseAggConnector.pull_model_updates_ready_for_aggregation()
    • BaseAggConnector.pull_model_requirements()
    • BaseAggConnector.register_model_updates_for_aggregation()
    • BaseAggConnector.pull_model_updates_registered_for_aggregation()
    • BaseAggConnector.pull_model_updates_data()
    • BaseAggConnector.prep_model_data_for_storage()
    • BaseAggConnector.post_new_model_aggregate()
    • BaseAggConnector.pull_model_updates_pending_aggregation()
    • BaseAggConnector.register_model_update_used_in_aggregate()
    • BaseAggConnector.register_model_updates_use_in_aggregation_complete()
    • BaseAggConnector.register_model_updates_use_in_aggregation_failed()
    • BaseAggConnector.update_metadata_database_arch()
• Aggregator Utils
  • AutoSubRegistrationMeta
    • AutoSubRegistrationMeta.mro()
    • AutoSubRegistrationMeta.register()
• Api Handler Factory
  • call_api_handler()
• Api Handler Utils
  • register()
• Metadata Connectors Factory
  • BaseMetadataConnector
    • BaseMetadataConnector.create()
    • BaseMetadataConnector.pull_federated_model_w_id()
    • BaseMetadataConnector.pull_latest_model_aggregate()
    • BaseMetadataConnector.pull_model_updates_ready_for_aggregation()
    • BaseMetadataConnector.pull_model_requirements()
    • BaseMetadataConnector.register_model_updates_for_aggregation()
    • BaseMetadataConnector.pull_model_updates_registered_for_aggregation()
    • BaseMetadataConnector.post_new_model_aggregate()
    • BaseMetadataConnector.pull_model_updates_pending_aggregation()
    • BaseMetadataConnector.register_model_update_used_in_aggregate()
    • BaseMetadataConnector.register_model_updates_use_in_aggregation_complete()
    • BaseMetadataConnector.update_database()
• Model Data Connectors Factory
  • BaseModelDataConnector
    • BaseModelDataConnector.create()
    • BaseModelDataConnector.push_model_data_to_storage()
    • BaseModelDataConnector.pull_model_updates_data()
    • BaseModelDataConnector.prep_model_data_for_storage()
• Tasks
  • agg_service()
  • post_agg_service_hook()
  • update_metadata_db()