def supervise(project, workspace, namespace, workflow,<EOL>sample_sets, recovery_file):
<EOL>logging.info("<STR_LIT>")<EOL>logging.info("<STR_LIT>" + recovery_file)<EOL>args = {<EOL>'<STR_LIT>'  : project,<EOL>'<STR_LIT>': workspace,<EOL>'<STR_LIT>': namespace,<EOL>'<STR_LIT>' : workflow,<EOL>'<STR_LIT>': sample_sets<EOL>}<EOL>monitor_data, dependencies = init_supervisor_data(workflow, sample_sets)<EOL>recovery_data = {<EOL>'<STR_LIT:args>' : args,<EOL>'<STR_LIT>' : monitor_data,<EOL>'<STR_LIT>' : dependencies<EOL>}<EOL>supervise_until_complete(monitor_data, dependencies, args, recovery_file)<EOL>
Supervise submission of jobs from a Firehose-style workflow of workflows