Changeset View
Changeset View
Standalone View
Standalone View
swh/provenance/storage/rabbitmq/client.py
Show First 20 Lines • Show All 65 Lines • ▼ Show 20 Lines | if relation is not None: | ||||
rel, RelationData | rel, RelationData | ||||
), "Values in the dictionary must be RelationData structures" | ), "Values in the dictionary must be RelationData structures" | ||||
ranges.setdefault(key, set()).add((src, rel.dst, rel.path)) | ranges.setdefault(key, set()).add((src, rel.dst, rel.path)) | ||||
else: | else: | ||||
items: Union[Set[Tuple[bytes, Any]], Set[Tuple[bytes]]] | items: Union[Set[Tuple[bytes, Any]], Set[Tuple[bytes]]] | ||||
if isinstance(data, dict): | if isinstance(data, dict): | ||||
items = set(data.items()) | items = set(data.items()) | ||||
else: | else: | ||||
# TODO this is probably not used any more | |||||
items = {(item,) for item in data} | items = {(item,) for item in data} | ||||
for id, *rest in items: | for id, *rest in items: | ||||
key = ProvenanceStorageRabbitMQServer.get_routing_key(id, meth_name) | key = ProvenanceStorageRabbitMQServer.get_routing_key(id, meth_name) | ||||
ranges.setdefault(key, set()).add((id, *rest)) | ranges.setdefault(key, set()).add((id, *rest)) | ||||
return ranges | return ranges | ||||
class MetaRabbitMQClient(type): | class MetaRabbitMQClient(type): | ||||
▲ Show 20 Lines • Show All 426 Lines • Show Last 20 Lines |