test_tasks.py 文件源码

def test_transcode_video_restart(self):
        video = factories.VideoFactory(public_id='videoid')
        models.ProcessingState.objects.filter(video=video).update(status=models.ProcessingState.STATUS_RESTART)

        mock_backend = Mock(return_value=Mock(
            start_transcoding=Mock(return_value=[]),
            iter_formats=Mock(return_value=[]),
        ))
        with override_settings(PLUGIN_BACKEND=mock_backend):
            tasks.transcode_video_restart()

        mock_backend.return_value.start_transcoding.assert_called_once_with('videoid')
        self.assertEqual(
            models.ProcessingState.STATUS_SUCCESS,
            models.ProcessingState.objects.get(video=video).status
        )