(*args, **kwargs)
| 156 | |
| 157 | @functools.wraps(func) |
| 158 | def wrapper(*args, **kwargs): |
| 159 | if not is_distributed(): |
| 160 | return func(*args, **kwargs) |
| 161 | |
| 162 | ret = func(*args, **kwargs) |
| 163 | group_barrier() |
| 164 | return ret |
| 165 | |
| 166 | return wrapper |
| 167 |
nothing calls this directly
no test coverage detected