Runs the test pipeline for each TEST
"""
+import moe.config
+
def init(e):
def hook_m_50(e):
e.main_pipe.insert(50, 'dummy tasktype hook_m_50', hook_m_50)
def hook_m_60(e):
- e.log.info('Here should be test pipeline running')
+ e.log.info('Here we run test pipeline')
tests = e['TESTS'].split()
for t in tests:
e.log.info('Running test %s' % t)
e.log.user.info('TEST %s ...' % t)
- op = moe.config.Operation('SET', None, t, level=70, source='<dummy tasktype>')
+ op = moe.config.Operation('SET', None, moe.config.ConfigExpression([t]), level=70, source='<dummy tasktype>')
testvar = e.config.lookup('TEST')
# Add and remove operation setting 'TEST="..."'
testvar.add_operation(op)
- e.test_pipeline.run()
+ e.test_pipe.run(e=e)
testvar.remove_operation(op)
e.main_pipe.insert(60, 'dummy tasktype hook_m_60', hook_m_60)