{"head":"994913503b930e1d9aaa128a1f6b9fd6f96706f4","size":2,"push_id":44292348,"shas":[["a4d0748dec6d6c64c1d47343c616d130565ac6b5","0deb23bd790735abba54d52582acefbf01ea3a1a@allstontrading.com","Added ability to pipe stdout and stderr through the disco worker protocol.","Luke Hoersten"],["994913503b930e1d9aaa128a1f6b9fd6f96706f4","0deb23bd790735abba54d52582acefbf01ea3a1a@allstontrading.com","Moved java disco worker to org.discoproject package.\n\n--HG--\nrename : src/com/allstontrading/disco/DiscoMapFunction.java => src/org/discoproject/DiscoMapFunction.java\nrename : src/com/allstontrading/disco/DiscoReduceFunction.java => src/org/discoproject/DiscoReduceFunction.java\nrename : src/com/allstontrading/disco/DiscoUtils.java => src/org/discoproject/DiscoUtils.java\nrename : src/com/allstontrading/disco/job/DiscoJob.java => src/org/discoproject/job/DiscoJob.java\nrename : src/com/allstontrading/disco/job/DiscoWorkerRunScript.java => src/org/discoproject/job/DiscoWorkerRunScript.java\nrename : src/com/allstontrading/disco/job/ExampleDiscoJob.java => src/org/discoproject/job/ExampleDiscoJob.java\nrename : src/com/allstontrading/disco/job/jobpack/DiscoJobPack.java => src/org/discoproject/job/jobpack/DiscoJobPack.java\nrename : src/com/allstontrading/disco/job/jobpack/DiscoJobPackUtils.java => src/org/discoproject/job/jobpack/DiscoJobPackUtils.java\nrename : src/com/allstontrading/disco/job/jobpack/DiscoScheduler.java => src/org/discoproject/job/jobpack/DiscoScheduler.java\nrename : src/com/allstontrading/disco/worker/DiscoWorker.java => src/org/discoproject/worker/DiscoWorker.java\nrename : src/com/allstontrading/disco/worker/DiscoWorkerMain.java => src/org/discoproject/worker/DiscoWorkerMain.java\nrename : src/com/allstontrading/disco/worker/protocol/DiscoIOChannel.java => src/org/discoproject/worker/protocol/DiscoIOChannel.java\nrename : src/com/allstontrading/disco/worker/protocol/decode/DiscoWorkerDecoder.java => src/org/discoproject/worker/protocol/decoder/DiscoWorkerDecoder.java\nrename : src/com/allstontrading/disco/worker/protocol/decode/DiscoWorkerListener.java => src/org/discoproject/worker/protocol/decoder/DiscoWorkerListener.java\nrename : src/com/allstontrading/disco/worker/protocol/decode/FailDecoder.java => src/org/discoproject/worker/protocol/decoder/FailDecoder.java\nrename : src/com/allstontrading/disco/worker/protocol/decode/HeaderDecoder.java => src/org/discoproject/worker/protocol/decoder/HeaderDecoder.java\nrename : src/com/allstontrading/disco/worker/protocol/decode/InputDecoder.java => src/org/discoproject/worker/protocol/decoder/InputDecoder.java\nrename : src/com/allstontrading/disco/worker/protocol/decode/OkDecoder.java => src/org/discoproject/worker/protocol/decoder/OkDecoder.java\nrename : src/com/allstontrading/disco/worker/protocol/decode/RetryDecoder.java => src/org/discoproject/worker/protocol/decoder/RetryDecoder.java\nrename : src/com/allstontrading/disco/worker/protocol/decode/TaskDecoder.java => src/org/discoproject/worker/protocol/decoder/TaskDecoder.java\nrename : src/com/allstontrading/disco/worker/protocol/decode/WaitDecoder.java => src/org/discoproject/worker/protocol/decoder/WaitDecoder.java\nrename : src/com/allstontrading/disco/worker/protocol/decode/types/DiscoInput.java => src/org/discoproject/worker/protocol/decoder/types/DiscoInput.java\nrename : src/com/allstontrading/disco/worker/protocol/decode/types/DiscoInputFlag.java => src/org/discoproject/worker/protocol/decoder/types/DiscoInputFlag.java\nrename : src/com/allstontrading/disco/worker/protocol/decode/types/DiscoInputReplica.java => src/org/discoproject/worker/protocol/decoder/types/DiscoInputReplica.java\nrename : src/com/allstontrading/disco/worker/protocol/decode/types/DiscoInputReplicaProtocol.java => src/org/discoproject/worker/protocol/decoder/types/DiscoInputReplicaProtocol.java\nrename : src/com/allstontrading/disco/worker/protocol/decode/types/DiscoInputStatus.java => src/org/discoproject/worker/protocol/decoder/types/DiscoInputStatus.java\nrename : src/com/allstontrading/disco/worker/protocol/decode/types/DiscoTaskMode.java => src/org/discoproject/worker/protocol/decoder/types/DiscoTaskMode.java\nrename : src/com/allstontrading/disco/worker/protocol/decode/types/JsonDiscoInputReplicaDecoder.java => src/org/discoproject/worker/protocol/decoder/types/JsonDiscoInputReplicaDecoder.java\nrename : src/com/allstontrading/disco/worker/protocol/decode/types/ResponseMessageName.java => src/org/discoproject/worker/protocol/decoder/types/ResponseMessageName.java\nrename : src/com/allstontrading/disco/worker/protocol/encode/AbstractDiscoWorkerEncoder.java => src/org/discoproject/worker/protocol/encoder/AbstractDiscoWorkerEncoder.java\nrename : src/com/allstontrading/disco/worker/protocol/encode/DoneEncoder.java => src/org/discoproject/worker/protocol/encoder/DoneEncoder.java\nrename : src/com/allstontrading/disco/worker/protocol/encode/ErrorEncoder.java => src/org/discoproject/worker/protocol/encoder/ErrorEncoder.java\nrename : src/com/allstontrading/disco/worker/protocol/encode/FatalEncoder.java => src/org/discoproject/worker/protocol/encoder/FatalEncoder.java\nrename : src/com/allstontrading/disco/worker/protocol/encode/InputErrorEncoder.java => src/org/discoproject/worker/protocol/encoder/InputErrorEncoder.java\nrename : src/com/allstontrading/disco/worker/protocol/encode/MessageEncoder.java => src/org/discoproject/worker/protocol/encoder/MessageEncoder.java\nrename : src/com/allstontrading/disco/worker/protocol/encode/OutputEncoder.java => src/org/discoproject/worker/protocol/encoder/OutputEncoder.java\nrename : src/com/allstontrading/disco/worker/protocol/encode/PingEncoder.java => src/org/discoproject/worker/protocol/encoder/PingEncoder.java\nrename : src/com/allstontrading/disco/worker/protocol/encode/RequestInputsEncoder.java => src/org/discoproject/worker/protocol/encoder/RequestInputsEncoder.java\nrename : src/com/allstontrading/disco/worker/protocol/encode/RequestTaskEncoder.java => src/org/discoproject/worker/protocol/encoder/RequestTaskEncoder.java\nrename : src/com/allstontrading/disco/worker/protocol/encode/WorkerAnnounceEncoder.java => src/org/discoproject/worker/protocol/encoder/WorkerAnnounceEncoder.java\nrename : src/com/allstontrading/disco/worker/protocol/encode/types/OutputType.java => src/org/discoproject/worker/protocol/encoder/types/OutputType.java\nrename : src/com/allstontrading/disco/worker/protocol/encode/types/RequestMessageName.java => src/org/discoproject/worker/protocol/encoder/types/RequestMessageName.java\nrename : src/com/allstontrading/disco/worker/task/DiscoMapTask.java => src/org/discoproject/worker/task/DiscoMapTask.java\nrename : src/com/allstontrading/disco/worker/task/DiscoReduceTask.java => src/org/discoproject/worker/task/DiscoReduceTask.java\nrename : src/com/allstontrading/disco/worker/task/DiscoTask.java => src/org/discoproject/worker/task/DiscoTask.java\nrename : src/com/allstontrading/disco/worker/task/DiscoTaskInputFetcher.java => src/org/discoproject/worker/task/DiscoTaskInputFetcher.java","Luke Hoersten"]],"ref":"refs/heads/master"}