class test(object):
def execute(self, args):
- print "test args %s" % args
+ print("test args %s" % args)
class GraphFlowTest(unittest.TestCase):
gf.join()
gf.task_manager.wait_tasks_done(gf.sort_nodes)
task_set = gf.task_manager.get_all_task()
- for task in task_set.itervalues():
+ for task in list(task_set.values()):
self.assertEqual(task.FINISHED, task.status)
def test_async_task(self):
gf.join()
gf.task_manager.wait_tasks_done(gf.sort_nodes)
task_set = gf.task_manager.get_all_task()
- for task in task_set.itervalues():
+ for task in list(task_set.values()):
self.assertEqual(task.FINISHED, task.status)
@mock.patch.object(restcall, 'call_req')
gf.join()
gf.task_manager.wait_tasks_done(gf.sort_nodes)
task_set = gf.task_manager.get_all_task()
- for task in task_set.itervalues():
+ for task in list(task_set.values()):
self.assertEqual(task.FINISHED, task.status)