1. A method implemented in a computing environment including a compute entity comprising a source commutatively coupled to a plurality of compute entities comprising sinks, the method comprising: managing execution of a job comprising executable code using the source; offloading sections of the executable code to the plurality of sinks; storing, for each section of code that is offloaded to a sink, offload context information identifying the section of code that is offloaded and the sink it is offloaded to; receiving, for offloaded sections of code, results generated by the sinks to which the sections of code were offloaded; detecting that a sink has failed to successfully execute a section of code that was offloaded to the sink, and in response thereto, retrieving the offload context information corresponding to the section of code offloaded to the sink; and offloading the section of code to another sink for execution.