'task_queue = [ ]
processing = [ ]'

def test_90_newtask_with_itag(self):

    time.sleep(0.1)
    self.newtask_queue.put({'taskid': 'taskid', 'project': 'test_project', 'url': 'url', 'fetch': {'data': 'abc'}, 'process': {'data': 'abc'}, 'schedule': {'itag': 'abc', 'retries': 1}})
    task = self.scheduler2fetcher.get(timeout=10)
    self.assertIsNotNone(task)
    self.assertEqual(task['taskid'], 'taskid')
    self.test_70_taskdone_ok()
    self.test_75_on_finished_msg()
