Changeset View

Standalone View

	from os import path
	import swh.indexer			import swh.indexer
				import os
				from os import path

				from celery import shared_task
				from celery.contrib.testing.worker import _start_worker_thread
				from celery import current_app

				__all__ = ['start_worker_thread']

				DATA_DIR = path.join(path.dirname(__file__), 'data')
	SQL_DIR = path.join(path.dirname(swh.indexer.__file__), 'sql')			SQL_DIR = path.join(path.dirname(swh.indexer.__file__), 'sql')

				os.environ['CELERY_BROKER_URL'] = 'memory://'
				os.environ['CELERY_RESULT_BACKEND'] = 'redis://localhost'
				os.environ['CELERY_TASK_SERIALIZER'] = 'msgpack'
				current_app.conf.update(
				task_serializer='msgpack',
				)


				def start_worker_thread():
				return _start_worker_thread(current_app, loglevel='DEBUG')


				# Needed to pass an assertion, see
				# https://github.com/celery/celery/pull/5111
				@shared_task(name='celery.ping')
				def ping():
				ardumontUnsubmitted Done Inline Actions To avoid repeating myself, D518#inline-2716. Also, maybe stack this diff onto D518? ardumont: To avoid repeating myself, D518#inline-2716. Also, maybe stack this diff onto D518?
				return 'pong'