Changeset View
Changeset View
Standalone View
Standalone View
swh/provenance/storage/rabbitmq/server.py
| Show First 20 Lines • Show All 474 Lines • ▼ Show 20 Lines | class ProvenanceStorageRabbitMQWorker(multiprocessing.Process): | ||||
| @staticmethod | @staticmethod | ||||
| def get_conflicts_func(meth_name: str) -> Callable[[Iterable[Any]], Any]: | def get_conflicts_func(meth_name: str) -> Callable[[Iterable[Any]], Any]: | ||||
| if meth_name == "content_add": | if meth_name == "content_add": | ||||
| return resolve_dates | return resolve_dates | ||||
| elif meth_name == "directory_add": | elif meth_name == "directory_add": | ||||
| return resolve_directory | return resolve_directory | ||||
| elif meth_name == "location_add": | elif meth_name == "location_add": | ||||
| return lambda data: set(data) # just remove duplicates | return lambda data: dict(data) | ||||
| elif meth_name == "origin_add": | elif meth_name == "origin_add": | ||||
| return lambda data: dict(data) # last processed value is good enough | return lambda data: dict(data) # last processed value is good enough | ||||
| elif meth_name == "revision_add": | elif meth_name == "revision_add": | ||||
| return resolve_revision | return resolve_revision | ||||
| elif meth_name == "relation_add": | elif meth_name == "relation_add": | ||||
| return resolve_relation | return resolve_relation | ||||
| else: | else: | ||||
| LOGGER.warning( | LOGGER.warning( | ||||
| ▲ Show 20 Lines • Show All 247 Lines • Show Last 20 Lines | |||||