def init(e):
- def hook_m_50:
- e.log.info('Here should be compiling')
-
- e.main_pipeline.insert(hook_m_50, 'dummy tasktype hook_m_50', 50)
-
- def hook_m_60:
- e.log.info('Here should be test pipeline running')
- tests = e['TESTS'].split()
- for t in tests:
- e.log.info('Running test %s' % t)
- e.log.user.info('TEST %s ...' % t)
+ def hook_m_50(self):
+ e.log.info('Here should be compiling')
- op = moe.config.Operation('SET', None, 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()
- testvar.remove_operation(op)
-
- e.main_pipeline.insert(hook_m_60, 'dummy tasktype hook_m_60', 60)
-
- def hook_t_30:
- e.log.info("Maybe we should do something? Nah...")
-
- e.test_pipeline.insert(hook_t_30, 'dummy tasktype hook_t_30', 30)
+ e.main_pipe.insert(hook_m_50, 'dummy tasktype hook_m_50', 50)
+
+ def hook_m_60(self):
+ e.log.info('Here should be test pipeline running')
+ 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>')
+ testvar = e.config.lookup('TEST')
+ # Add and remove operation setting 'TEST="..."'
+ testvar.add_operation(op)
+ e.test_pipeline.run()
+ testvar.remove_operation(op)
+
+ e.main_pipe.insert(hook_m_60, 'dummy tasktype hook_m_60', 60)
+
+ def hook_t_30(self):
+ e.log.info("Maybe we should do something? Nah...")
+
+ e.test_pipe.insert(hook_t_30, 'dummy tasktype hook_t_30', 30)