(self)
| 22 | self._tracker = Tracker() |
| 23 | |
| 24 | def exec(self): |
| 25 | envelope = self.inp.recv() |
| 26 | if envelope is None: |
| 27 | logger.info('stream tracker finish') |
| 28 | return |
| 29 | |
| 30 | msg = envelope.msg |
| 31 | if msg['process']: |
| 32 | items = msg['items'] |
| 33 | |
| 34 | tracks, failed_ids = self._tracker.track(items) |
| 35 | msg['tracks'] = tracks |
| 36 | msg['failed_ids'] = failed_ids |
| 37 | # logger.debug(f'track output: {tracks}, failed_ids: {failed_ids}') |
| 38 | self.out.send(envelope) |