(self, fetcher, instance)
| 29 | track_peers = True |
| 30 | |
| 31 | def fetch(self, fetcher, instance): |
| 32 | instances = [ |
| 33 | peer |
| 34 | for peer_weakref in instance._state.peers |
| 35 | if (peer := peer_weakref()) is not None |
| 36 | ] |
| 37 | if len(instances) > 1: |
| 38 | fetcher.fetch_many(instances) |
| 39 | else: |
| 40 | fetcher.fetch_one(instance) |
| 41 | |
| 42 | def __reduce__(self): |
| 43 | return "FETCH_PEERS" |
nothing calls this directly
no test coverage detected