Differential D8593 Diff 31023 swh/provenance/storage/rabbitmq/client.py

Changeset View

Standalone View

	Show All 18 Lines
	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.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.core.statsd import statsd			from swh.core.statsd import statsd
				from swh.provenance.storage import get_provenance_storage
				from swh.provenance.storage.interface import (
				ProvenanceStorageInterface,
				RelationData,
				RelationType,
				)

	from .. import get_provenance_storage
	from ..interface import ProvenanceStorageInterface, RelationData, RelationType
	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__)
	▲ Show 20 Lines • Show All 466 Lines • Show Last 20 Lines