task-distribution 0.1.0.1 → 0.1.0.2
raw patch · 3 files changed
+11/−5 lines, 3 filesdep ~hadoop-rpc
Dependency ranges changed: hadoop-rpc
Files
- src/Control/Distributed/Task/Distribution/TaskDistribution.hs +1/−0
- src/Control/Distributed/Task/TaskSpawning/BinaryStorage.hs +6/−1
- task-distribution.cabal +4/−4
src/Control/Distributed/Task/Distribution/TaskDistribution.hs view
@@ -293,6 +293,7 @@ transportedResult <- ( do acceptTime <- liftIO getCurrentTime+ liftIO $ putStrLn $ "processing: " ++ taskName say $ "processing: " ++ taskName results <- liftIO (processTasks taskDef dataDefs resultDef) say $ "processing done for: " ++ taskName
src/Control/Distributed/Task/TaskSpawning/BinaryStorage.hs view
@@ -8,6 +8,8 @@ import Data.Hashable (hash) import System.Directory +import Control.Distributed.Task.Util.Logging+ calculateHash :: BL.ByteString -> Int calculateHash = hash @@ -16,7 +18,10 @@ (filePath, fileExists) <- getFilePath fileHash if fileExists then return ()- else BL.writeFile filePath content+ else (do+ logInfo $ "storing task at "++filePath+ BL.writeFile filePath content+ ) get :: Int -> IO (Maybe FilePath) get fileHash = do
task-distribution.cabal view
@@ -1,5 +1,5 @@ name: task-distribution-version: 0.1.0.1+version: 0.1.0.2 synopsis: Initial project template from stack description: Please see README.md homepage: http://github.com/michaxm/task-distribution#readme@@ -65,7 +65,7 @@ , hashable , zlib , bzlib- , hadoop-rpc < 1.1+ , hadoop-rpc , vector , containers , async@@ -121,7 +121,7 @@ , filepath , distributed-process , async- , hadoop-rpc < 1.1+ , hadoop-rpc , vector , text , zlib@@ -178,7 +178,7 @@ , rank1dynamic , distributed-static , text- , hadoop-rpc < 1.1+ , hadoop-rpc , vector , split , hslogger