def init(e):
- def hook_m_50(self):
+ def hook_m_50(e):
e.log.info('Here should be compiling')
- e.main_pipe.insert(hook_m_50, 'dummy tasktype hook_m_50', 50)
+ e.main_pipe.insert(50, 'dummy tasktype hook_m_50', hook_m_50)
- def hook_m_60(self):
+ def hook_m_60(e):
e.log.info('Here should be test pipeline running')
tests = e['TESTS'].split()
for t in tests:
e.test_pipeline.run()
testvar.remove_operation(op)
- e.main_pipe.insert(hook_m_60, 'dummy tasktype hook_m_60', 60)
+ e.main_pipe.insert(60, 'dummy tasktype hook_m_60', hook_m_60)
- def hook_t_30(self):
+ def hook_t_30(e):
e.log.info("Maybe we should do something? Nah...")
- e.test_pipe.insert(hook_t_30, 'dummy tasktype hook_t_30', 30)
+ e.test_pipe.insert(30, 'dummy tasktype hook_t_30', hook_t_30)