Did I find the right examples for you? yes no

All Samples(2)  |  Call(1)  |  Derive(0)  |  Import(1)

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/proc.py   ciel(Download)
from ciel.runtime.exceptions import BlameUserException, TaskFailedError,\
    MissingInputException, ReferenceUnavailableException
from ciel.runtime.executors import ContextManager,\
    spawn_task_helper, OngoingOutput, package_lookup
import subprocess
        output_name = self.expected_outputs[index]
        can_accept_fd = (fd_socket_name is not None)
        output_ctx = OngoingOutput(output_name, index, can_smart_subscribe, may_pipe, make_local_sweetheart, can_accept_fd, self)
        self.ongoing_outputs[index] = output_ctx
        self.context_manager.add_context(output_ctx)