	Show All 27 Lines

	def get_sched():			def get_sched():
	global scheduler			global scheduler
	if not scheduler:			if not scheduler:
	scheduler = get_scheduler_from(**app.config['scheduler'])			scheduler = get_scheduler_from(**app.config['scheduler'])
	return scheduler			return scheduler


				def has_no_empty_params(rule):
				return len(rule.defaults or ()) >= len(rule.arguments or ())


	@app.route('/')			@app.route('/')
	@negotiate(MsgpackFormatter)			@negotiate(MsgpackFormatter)
	@negotiate(JSONFormatter)			@negotiate(JSONFormatter)
	def index():			def index():
	return 'SWH Scheduler API server'			return 'SWH Scheduler API server'


	@app.route('/close_connection', methods=['GET', 'POST'])			@app.route('/close_connection', methods=['GET', 'POST'])
	▲ Show 20 Lines • Show All 110 Lines • ▼ Show 20 Lines

	@app.route('/delete_archived_tasks', methods=['POST'])			@app.route('/delete_archived_tasks', methods=['POST'])
	@negotiate(MsgpackFormatter)			@negotiate(MsgpackFormatter)
	@negotiate(JSONFormatter)			@negotiate(JSONFormatter)
	def delete_archived_tasks():			def delete_archived_tasks():
	return get_sched().delete_archived_tasks(**decode_request(request))			return get_sched().delete_archived_tasks(**decode_request(request))


				@app.route("/site-map")
				@negotiate(MsgpackFormatter)
				@negotiate(JSONFormatter)
				def site_map():
				links = []
				sched = get_sched()
				for rule in app.url_map.iter_rules():
				if has_no_empty_params(rule) and hasattr(sched, rule.endpoint):
				links.append(dict(
				rule=rule.rule,
				description=getattr(sched, rule.endpoint).__doc__))
				# links is now a list of url, endpoint tuples
				return links


	def run_from_webserver(environ, start_response,			def run_from_webserver(environ, start_response,
	config_path=DEFAULT_CONFIG_PATH):			config_path=DEFAULT_CONFIG_PATH):
	"""Run the WSGI app from the webserver, loading the configuration."""			"""Run the WSGI app from the webserver, loading the configuration."""
	cfg = config.load_named_config(config_path, DEFAULT_CONFIG)			cfg = config.load_named_config(config_path, DEFAULT_CONFIG)
	app.config.update(cfg)			app.config.update(cfg)
	handler = logging.StreamHandler()			handler = logging.StreamHandler()
	app.logger.addHandler(handler)			app.logger.addHandler(handler)
	return app(environ, start_response)			return app(environ, start_response)


	if __name__ == '__main__':			if __name__ == '__main__':
	print('Please use the "swh-scheduler api-server" command')			print('Please use the "swh-scheduler api-server" command')

docker-compose.search.yml: Specify the search journal client configClosedPublicActions

Details

Diff Detail

Event Timeline

Revision ContentsChangeset List

Diff 16667

docker/conf/search_journal_client_objects.yml

docker-compose.search.yml: Specify the search journal client config
ClosedPublic
Actions

Revision Contents
Changeset List