Skip to content

Commit

Permalink
Update aggregator.py
Browse files Browse the repository at this point in the history
Signed-off-by: Parth Mandaliya <parthx.mandaliya@intel.com>
  • Loading branch information
ParthM-GitHub committed Sep 28, 2023
1 parent b1b641e commit 04e5297
Showing 1 changed file with 1 addition and 8 deletions.
9 changes: 1 addition & 8 deletions openfl/interface/aggregator.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,8 +3,6 @@
"""Aggregator module."""

import sys
import threading

from logging import getLogger

from click import echo
Expand Down Expand Up @@ -56,12 +54,7 @@ def start_(plan, authorized_cols, secure):

logger.info('🧿 Starting the Aggregator Service.')

agg_server = plan.get_server()

plan.aggregator_.agg_grpc_server_start = threading.Thread(target=agg_server.serve)
plan.aggregator_.start_flow_execution = threading.Thread(target=plan.aggregator_.run_flow_until_transition)
plan.aggregator_.agg_grpc_server_start.start()
plan.aggregator_.start_flow_execution.start()
plan.get_server().serve()


@aggregator.command(name='generate-cert-request')
Expand Down

0 comments on commit 04e5297

Please sign in to comment.