'task_queue = [ ]'

def test_35_new_task(self):

    time.sleep(0.2)
    self.newtask_queue.put({'taskid': 'taskid', 'project': 'test_project', 'url': 'url', 'fetch': {'data': 'abc'}, 'process': {'data': 'abc'}, 'schedule': {'age': 0}})
    time.sleep(0.5)
    task = self.scheduler2fetcher.get(timeout=10)
    self.assertGreater(len(self.rpc.get_active_tasks()), 0)
    self.assertIsNotNone(task)
    self.assertEqual(task['taskid'], 'taskid')
    self.assertEqual(task['project'], 'test_project')
    self.assertIn('schedule', task)
    self.assertIn('fetch', task)
    self.assertIn('process', task)
    self.assertIn('track', task)
    self.assertEqual(task['fetch']['data'], 'abc')
