diff --git a/salt/utils/asynchronous.py b/salt/utils/asynchronous.py index 911088a3c29..016fe1748d0 100644 --- a/salt/utils/asynchronous.py +++ b/salt/utils/asynchronous.py @@ -63,7 +63,8 @@ class SyncWrapper: self.cls = cls if loop_kwarg: kwargs[self.loop_kwarg] = self.io_loop - self.obj = cls(*args, **kwargs) + with current_ioloop(self.io_loop): + self.obj = cls(*args, **kwargs) self._async_methods = list( set(async_methods + getattr(self.obj, "async_methods", [])) )