Function orchestrator::run

• Defined in File orchestrator.py

Function Documentation

orchestrator.run(flux_uri, rmq_config, file=None, fake_flux=False, fake_rmq_update=False, fake_rmq_publish=False)

The driver to start the orchestrator. It effectively connects all the pipeline steps