Did I find the right examples for you? yes no

All Samples(7)  |  Call(0)  |  Derive(3)  |  Import(4)

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/simple.py   ciel(Download)
import subprocess
from subprocess import PIPE
from ciel.runtime.executors.base import BaseExecutor
from ciel.runtime.exceptions import BlameUserException
from ciel.runtime.executors import hash_update_with_structure,\
class SimpleExecutor(BaseExecutor):
 
    def __init__(self, worker):
        BaseExecutor.__init__(self, worker)
 

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/init.py   ciel(Download)
# ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
# OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
from ciel.runtime.executors.base import BaseExecutor
import pickle
from ciel.runtime.exceptions import BlameUserException
class InitExecutor(BaseExecutor):
 
    handler_name = "init"
 
    def __init__(self, worker):

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/proc.py   ciel(Download)
    SW2_FixedReference, SW2_FutureReference, SWErrorReference
import pickle
from ciel.runtime.executors.base import BaseExecutor
from ciel.runtime.producer import write_fixed_ref_string, ref_from_string,\
    ref_from_safe_string
class ProcExecutor(BaseExecutor):
    """Executor for running generic processes."""
 
    handler_name = "proc"
 

src/c/i/ciel-HEAD/src/python/ciel/runtime/task_executor.py   ciel(Download)
import time
import urlparse
from ciel.runtime.executors.base import BaseExecutor
 
class TaskExecutorPlugin(AsynchronousExecutePlugin):