'task_queue = [ test_project:taskid# ]'

def test_a40_success_recrawl(self):

    self.newtask_queue.put({'taskid': 'taskid', 'project': 'test_project', 'url': 'url', 'fetch': {'data': 'abc'}, 'process': {'data': 'abc'}, 'schedule': {'age': 0, 'retries': 1, 'auto_recrawl': True}})
    task1 = self.scheduler2fetcher.get(timeout=10)
    task2 = self.scheduler2fetcher.get(timeout=10)
    self.assertIsNotNone(task1)
    self.assertIsNotNone(task2)
    self.assertTrue(((task1['taskid'] == 'taskid#') or (task2['taskid'] == 'taskid#')))
    self.status_queue.put({'taskid': 'taskid', 'project': 'test_project', 'url': 'url', 'schedule': {'age': 0, 'retries': 1, 'auto_recrawl': True}, 'track': {'fetch': {'ok': True}, 'process': {'ok': True}}})
    task = self.scheduler2fetcher.get(timeout=10)
    self.assertIsNotNone(task)
