Bases: object
The control peer application will start runners as required for the flows/bricks
as described in the given config file. Once the runners have registered themselves,
they will get according assignments.
-
classmethod
create()[source]
“Create control peer
-
async static
install_bricks()[source]
get brick list from PackageManager and install bricks if necessary
-
install_signal_handlers()[source]
-
remove_runner(runner)[source]
-
async
run()[source]
run the application
-
schedule_shutdown(sig, _)[source]
-
async
shutdown()[source]
shut down the controlpeer
-
async
start_new_runner(brick)[source]
update the configuration and start the flow
-
async
stop_runners(flow_uid=None)[source]
stop all runners or all runners for the given flow.uid