diff --git a/om-fork.cabal b/om-fork.cabal
--- a/om-fork.cabal
+++ b/om-fork.cabal
@@ -1,6 +1,6 @@
 cabal-version:       3.0
 name:                om-fork
-version:             0.7.1.9
+version:             0.7.1.10
 synopsis:            Concurrency utilities.
 description:         Actor pattern and some limited structured concurrency
                      tools
@@ -21,7 +21,7 @@
     , aeson        >= 2.0.3.0  && < 2.3
     , base         >= 4.15.1.0 && < 4.20
     , exceptions   >= 0.10.4   && < 0.11
-    , ki           >= 1.0.0    && < 1.1
+    , ki-unlifted  >= 1.0.0.2  && < 1.1
     , monad-logger >= 0.3.36   && < 0.4
     , om-show      >= 0.1.2.6  && < 0.2
     , text         >= 1.2.5.0  && < 2.2
diff --git a/src/OM/Fork.hs b/src/OM/Fork.hs
--- a/src/OM/Fork.hs
+++ b/src/OM/Fork.hs
@@ -33,15 +33,17 @@
 import Control.Monad (void)
 import Control.Monad.Catch (MonadThrow(throwM), MonadCatch, SomeException,
   try)
-import Control.Monad.IO.Class (MonadIO, liftIO)
+import Control.Monad.IO.Class (MonadIO(liftIO))
 import Control.Monad.Logger.CallStack (MonadLogger, logInfo, logWarn)
-import Data.Aeson (ToJSON, toJSON)
+import Data.Aeson (ToJSON(toJSON))
 import Data.String (IsString)
 import Data.Text (Text)
 import GHC.Conc (atomically)
 import OM.Show (showt)
-import UnliftIO (MonadUnliftIO, askRunInIO, throwString)
-import qualified Ki
+import Prelude (Either(Left, Right), Monad((>>=), return),
+  Semigroup((<>)), Show(show), ($), (.), IO, Monoid)
+import UnliftIO (MonadUnliftIO, throwString)
+import qualified Ki.Unlifted as Ki
 
 
 {- | How to respond to a asynchronous message. -}
@@ -157,9 +159,8 @@
   => (Race => m a) {- ^ - @action@: The provided "race" action. -}
   -> m a
 runRace action = do
-  runInIO <- askRunInIO
-  liftIO . Ki.scoped $ \scope ->
-    runInIO (let ?scope = scope in action)
+  Ki.scoped $ \scope ->
+    let ?scope = scope in action
 
 
 {- |
@@ -189,15 +190,12 @@
   -> m a
   -> m ()
 race name action = do
-  runInIO <- askRunInIO
-  liftIO
-    . Ki.fork_ ?scope
-    $ do
-      tid <- myThreadId
-      runInIO . logUnexpectedTermination name $ do
-        logInfo $ "Starting thread (tid, name): " <> showt (tid, name)
-        void action
-      throwString $ "Thread Finished (tid, name): " <> show (tid, name)
+  Ki.fork_ ?scope $ do
+    tid <- liftIO myThreadId
+    logUnexpectedTermination name $ do
+      logInfo $ "Starting thread (tid, name): " <> showt (tid, name)
+      void action
+    throwString $ "Thread Finished (tid, name): " <> show (tid, name)
 
 
 {- | The name of a process. -}