'processing: [ test_project:taskid ]'

def test_a20_failed_retry(self):

    self.status_queue.put({'taskid': 'taskid', 'project': 'test_project', 'url': 'url', 'track': {'fetch': {'ok': True}, 'process': {'ok': False}}})
    task = self.scheduler2fetcher.get(timeout=5)
    self.assertIsNotNone(task)
    self.assertEqual(task['taskid'], 'taskid')
    self.status_queue.put({'taskid': 'taskid', 'project': 'test_project', 'url': 'url', 'track': {'fetch': {'ok': False}, 'process': {'ok': False}}})
    self.test_75_on_finished_msg()
    from six.moves import queue as Queue
    with self.assertRaises(Queue.Empty):
        self.scheduler2fetcher.get(timeout=5)
