diff --git a/swh/lister/cgit/tasks.py b/swh/lister/cgit/tasks.py --- a/swh/lister/cgit/tasks.py +++ b/swh/lister/cgit/tasks.py @@ -7,17 +7,9 @@ from .lister import CGitLister -def new_lister(url='https://git.kernel.org/', - url_prefix=None, - instance='kernal', **kw): - return CGitLister(url=url, instance=instance, url_prefix=url_prefix, - **kw) - - @app.task(name=__name__ + '.CGitListerTask') def cgit_lister(**lister_args): - lister = new_lister(**lister_args) - lister.run() + CGitLister(**lister_args).run() @app.task(name=__name__ + '.ping') diff --git a/swh/lister/cgit/tests/test_tasks.py b/swh/lister/cgit/tests/test_tasks.py --- a/swh/lister/cgit/tests/test_tasks.py +++ b/swh/lister/cgit/tests/test_tasks.py @@ -11,7 +11,7 @@ @patch('swh.lister.cgit.tasks.CGitLister') -def test_lister_no_url_prefix(lister, swh_app, celery_session_worker): +def test_lister(lister, swh_app, celery_session_worker): # setup the mocked CGitLister lister.return_value = lister lister.run.return_value = None @@ -25,29 +25,6 @@ lister.assert_called_once_with( url='https://git.kernel.org/', - url_prefix=None, instance='kernel') lister.db_last_index.assert_not_called() lister.run.assert_called_once_with() - - -@patch('swh.lister.cgit.tasks.CGitLister') -def test_lister_with_url_prefix(lister, swh_app, celery_session_worker): - # setup the mocked CGitLister - lister.return_value = lister - lister.run.return_value = None - - res = swh_app.send_task( - 'swh.lister.cgit.tasks.CGitListerTask', - kwargs=dict(url='https://cgit.kde.org/', - url_prefix='https://anongit.kde.org/', instance='kde')) - assert res - res.wait() - assert res.successful() - - lister.assert_called_once_with( - url='https://cgit.kde.org/', - url_prefix='https://anongit.kde.org/', - instance='kde') - lister.db_last_index.assert_not_called() - lister.run.assert_called_once_with()