| 189 | |
| 190 | |
| 191 | class Tuple(object): |
| 192 | def __init__(self, id, component, stream, task, values): |
| 193 | self.id = id |
| 194 | self.component = component |
| 195 | self.stream = stream |
| 196 | self.task = task |
| 197 | self.values = values |
| 198 | |
| 199 | def __repr__(self): |
| 200 | return '<%s%s>' % ( |
| 201 | self.__class__.__name__, |
| 202 | ''.join(' %s=%r' % (k, self.__dict__[k]) for k in sorted(self.__dict__.keys()))) |
| 203 | |
| 204 | def is_heartbeat_tuple(self): |
| 205 | return self.task == -1 and self.stream == "__heartbeat" |
| 206 | |
| 207 | |
| 208 | class Bolt(object): |