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 import shared_task
	from celery.contrib.testing.worker import _start_worker_thread			from celery.contrib.testing.worker import _start_worker_thread
	from celery import current_app			from celery import current_app

	__all__ = ['start_worker_thread']			__all__ = ['start_worker_thread']

	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():			def start_worker_thread():
	return _start_worker_thread(current_app)			return _start_worker_thread(current_app)


	# Needed to pass an assertion, see			# Needed to pass an assertion, see
	# https://github.com/celery/celery/pull/5111			# https://github.com/celery/celery/pull/5111
	@shared_task(name='celery.ping')			@shared_task(name='celery.ping')
	def 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'			return 'pong'