(self)
| 38 | self.user = user |
| 39 | |
| 40 | def poll(self): |
| 41 | while True: |
| 42 | try: |
| 43 | results = self.client.fetch(self.sql, self.handle) |
| 44 | if len(results.data) > 0: |
| 45 | raise Exception("Failed to kill query within time limit.") |
| 46 | except Exception as e: |
| 47 | self.exc = e |
| 48 | return |
| 49 | |
| 50 | def __enter__(self): |
| 51 | self.handle = self.client.execute_async(self.sql, user=self.user) |