mre /
kafka-influxdb
| Conditions | 4 |
| Total Lines | 10 |
| Lines | 0 |
| Ratio | 0 % |
| Changes | 1 | ||
| Bugs | 0 | Features | 0 |
| 1 | from functools import wraps |
||
| 7 | def timeout(seconds=5): |
||
| 8 | def decorator(func): |
||
| 9 | def wrapper(*args, **kwargs): |
||
| 10 | process = Process(None, func, None, args, kwargs) |
||
| 11 | process.start() |
||
| 12 | process.join(seconds) |
||
| 13 | if process.is_alive(): |
||
| 14 | process.terminate() |
||
| 15 | return wraps(func)(wrapper) |
||
| 16 | return decorator |
||
| 17 |
