distributed-fork 0.0.1.1 → 0.0.1.2

raw patch · 4 files changed

+8/−10 lines, 4 filesPVP: major bump suggested

API removals or changes: PVP suggests a major version bump

API changes (from Hackage documentation)

- Control.Distributed.Fork: ExecutorFailed :: Text -> ExecutorFinalStatus a

- Control.Distributed.Fork: ExecutorFinished :: (ExecutorFinalStatus a) -> ExecutorStatus a

- Control.Distributed.Fork: ExecutorPending :: ExecutorPendingStatus -> ExecutorStatus a

- Control.Distributed.Fork: ExecutorStarted :: (Maybe Text) -> ExecutorPendingStatus

- Control.Distributed.Fork: ExecutorSubmitted :: (Maybe Text) -> ExecutorPendingStatus

- Control.Distributed.Fork: ExecutorSucceeded :: a -> ExecutorFinalStatus a

- Control.Distributed.Fork: ExecutorWaiting :: (Maybe Text) -> ExecutorPendingStatus

- Control.Distributed.Fork: data ExecutorFinalStatus a

- Control.Distributed.Fork: data ExecutorPendingStatus

- Control.Distributed.Fork: data ExecutorStatus a

Files

distributed-fork.cabal +1/−1
src/Control/Distributed/Fork.hs +5/−7
src/Control/Distributed/Fork/Backend.hs +1/−1
src/Control/Distributed/Fork/Utils.hs +1/−1

distributed-fork.cabal view

@@ -1,5 +1,5 @@ name:                distributed-fork-version:             0.0.1.1+version:             0.0.1.2 synopsis:            Like 'forkIO', but uses remote machines instead of local threads. homepage:            https://github.com/utdemir/distributed-fork license:             BSD3

src/Control/Distributed/Fork.hs view

@@ -24,14 +24,12 @@ -- of scripts using Docker to overcome this limitation. module Control.Distributed.Fork   ( fork-  , await   , initDistributedFork   , Backend-  , Handle -  , ExecutorStatus (..)-  , ExecutorPendingStatus (..)-  , ExecutorFinalStatus (..)+  -- * Handle+  , Handle+  , await    -- * Exceptions   , ExecutorFailedException (..)@@ -66,8 +64,8 @@ -- main :: IO () -- main = do --   'initDistributedFork'---   handle <- 'fork' 'localProcessBackend' (static 'Dict') (static (return "Hello World!"))---   putStrLn =<< await handle+--   handle <- 'fork' 'Control.Distributed.Fork.LocalProcessBackend.localProcessBackend' (static 'Dict') (static (return "Hello World!"))+--   await handle >>= putStrLn -- @ fork :: Backend      -> Closure (Dict (Serializable a))

src/Control/Distributed/Fork/Backend.hs view

@@ -1,7 +1,7 @@ {-| You only need this module if you want to create a new backend for distributed-fork. -See 'Control.Distributed.Fork.LocalProcessBackend' for a minimal example.+See 'Control.Distributed.Fork.LocalProcessBackend.localProcessBackend' for a minimal example. -}  module Control.Distributed.Fork.Backend

src/Control/Distributed/Fork/Utils.hs view

@@ -13,7 +13,7 @@ import Control.Concurrent (threadDelay) import qualified System.Console.Terminal.Size as TS ---------------------------------------------------------------------------------import Control.Distributed.Fork.Internal (Handle (..))+import Control.Distributed.Fork.Internal import Control.Distributed.Fork --------------------------------------------------------------------------------