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 ised 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 | |||||