Differential D6273 Diff 23173 swh/provenance/api/client.py

Changeset View

Standalone View

swh/provenance/api/client.py

	Show All 12 Lines
	import uuid			import uuid

	import pika			import pika
	import pika.channel			import pika.channel
	import pika.connection			import pika.connection
	import pika.frame			import pika.frame
	import pika.spec			import pika.spec

	from swh.core.api import RPCClient
	from swh.core.api.serializers import encode_data_client as encode_data			from swh.core.api.serializers import encode_data_client as encode_data
	from swh.core.api.serializers import msgpack_loads as decode_data			from swh.core.api.serializers import msgpack_loads as decode_data
	from swh.provenance import get_provenance_storage			from swh.provenance import get_provenance_storage

	from ..interface import ProvenanceStorageInterface			from ..interface import ProvenanceStorageInterface
	from .serializers import DECODERS, ENCODERS			from .serializers import DECODERS, ENCODERS
	from .server import ProvenanceStorageRabbitMQServer			from .server import ProvenanceStorageRabbitMQServer

	LOG_FORMAT = (			LOG_FORMAT = (
	"%(levelname) -10s %(asctime)s %(name) -30s %(funcName) "			"%(levelname) -10s %(asctime)s %(name) -30s %(funcName) "
	"-35s %(lineno) -5d: %(message)s"			"-35s %(lineno) -5d: %(message)s"
	)			)
	LOGGER = logging.getLogger(__name__)			LOGGER = logging.getLogger(__name__)


	class ProvenanceStorageRPCClient(RPCClient):
	"""Proxy to a remote provenance storage API"""

	backend_class = ProvenanceStorageInterface
	extra_type_decoders = DECODERS
	extra_type_encoders = ENCODERS


	class ConfigurationError(Exception):
	pass


	class ResponseTimeout(Exception):			class ResponseTimeout(Exception):
	pass			pass


	class TerminateSignal(Exception):			class TerminateSignal(Exception):
	pass			pass


	▲ Show 20 Lines • Show All 498 Lines • Show Last 20 Lines