flambe.runner.garbage_collector

Script to run the garbage collector.

The garbage collector is in charge of destroying the factories once the experiment is over.

All useful information was sent to the orchestrator machine, so the Factories can be safely deleted.

To do this, the GarbageCollector gets the tasks from the Redis DB running in the Orchestrator. Once all tasks are over, it gets the factories from the Redis DB also (that’s why the Instances should be pickeable) and terminates them.

Module Contents

flambe.runner.garbage_collector.logger[source]
flambe.runner.garbage_collector.main(args: argparse.Namespace) → None[source]
flambe.runner.garbage_collector.parser[source]